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	Description
protected class	StompFrameHandlerV12.StompDecoderV12

Nested classes/interfaces inherited from class StompFrameHandlerV11

StompFrameHandlerV11.StompDecoderV11

Field Summary

Fields inherited from class StompFrameHandlerV11

ESC_CHAR

Fields inherited from class VersionedStompFrameHandler

connection, decoder, EMPTY_BODY, executorFactory, scheduledExecutorService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
StompFrame	createMessageFrame(ICoreMessage serverMessage, StompSubscription subscription, org.apache.activemq.artemis.core.server.ServerConsumer consumer, 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 StompFrameHandlerV11

createPingFrame, disconnect, getFailedAuthenticationResponse, getHeartBeater, initDecoder, onConnect, onDisconnect, onNack, onStomp, onUnsubscribe, replySent, requestAccepted

Methods inherited from class VersionedStompFrameHandler

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

Methods inherited from class Object

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

Constructor Details

StompFrameHandlerV12

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

Method Details

createStompFrame

public StompFrame createStompFrame(String command)

Overrides:

createStompFrame in class StompFrameHandlerV11

createMessageFrame

public StompFrame createMessageFrame(ICoreMessage serverMessage,
 StompSubscription subscription,
 org.apache.activemq.artemis.core.server.ServerConsumer consumer,
 int deliveryCount)
                              throws ActiveMQException

Overrides:

createMessageFrame in class VersionedStompFrameHandler

Throws:

ActiveMQException

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