org.apache.activemq.artemis.core.protocol.stomp.v12

Class StompFrameHandlerV12

java.lang.Object

org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler

org.apache.activemq.artemis.core.protocol.stomp.v11.StompFrameHandlerV11

org.apache.activemq.artemis.core.protocol.stomp.v12.StompFrameHandlerV12

All Implemented Interfaces:

FrameEventListener

public class StompFrameHandlerV12
extends StompFrameHandlerV11

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StompFrameHandlerV12.StompDecoderV12

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.protocol.stomp.v11.StompFrameHandlerV11

StompFrameHandlerV11.StompDecoderV11

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.protocol.stomp.v11.StompFrameHandlerV11

ESC_CHAR

Fields inherited from class org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler

connection, decoder, executorFactory, scheduledExecutorService

Constructor Summary

Constructors

Constructor and Description
StompFrameHandlerV12(StompConnection connection, ScheduledExecutorService scheduledExecutorService, ExecutorFactory factory)

Method Summary

Modifier and Type	Method and Description
StompFrame	createMessageFrame(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount)
StompFrame	createStompFrame(String command)
StompFrame	onAck(StompFrame request) Version 1.2's ACK frame only requires 'id' header here we use id = messageID

Methods inherited from class org.apache.activemq.artemis.core.protocol.stomp.v11.StompFrameHandlerV11

createPingFrame, initDecoder, onConnect, onDisconnect, onNack, onStomp, onUnsubscribe, replySent, requestAccepted

Methods inherited from class org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler

decode, getDecoder, getHandler, handleFrame, handleReceipt, hasBytes, onAbort, onBegin, onCommit, onError, onSend, onSubscribe, onUnknown, postprocess

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StompFrameHandlerV12

public StompFrameHandlerV12(StompConnection connection,
                            ScheduledExecutorService scheduledExecutorService,
                            ExecutorFactory factory)

Method Detail

createStompFrame

public StompFrame createStompFrame(String command)

Overrides:

createStompFrame in class StompFrameHandlerV11

createMessageFrame

public StompFrame createMessageFrame(ServerMessage serverMessage,
                                     StompSubscription subscription,
                                     int deliveryCount)
                              throws Exception

Overrides:

createMessageFrame in class VersionedStompFrameHandler

Throws:

Exception

onAck

public StompFrame onAck(StompFrame request)

Version 1.2's ACK frame only requires 'id' header here we use id = messageID

Overrides:

onAck in class StompFrameHandlerV11