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

Class VersionedStompFrameHandler

java.lang.Object

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

Direct Known Subclasses:

StompFrameHandlerV10, StompFrameHandlerV11

public abstract class VersionedStompFrameHandler
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected StompConnection	connection
protected StompDecoder	decoder
protected ExecutorFactory	executorFactory
protected ScheduledExecutorService	scheduledExecutorService

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	VersionedStompFrameHandler(StompConnection connection, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory)

Method Summary

Modifier and Type	Method and Description
StompFrame	createMessageFrame(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount)
abstract StompFrame	createStompFrame(String command)
StompFrame	decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
StompDecoder	getDecoder()
static VersionedStompFrameHandler	getHandler(StompConnection connection, StompVersions version, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory)
StompFrame	handleFrame(StompFrame request)
StompFrame	handleReceipt(String receiptID)
boolean	hasBytes()
void	initDecoder(VersionedStompFrameHandler existingHandler) this method is called when a newer version of handler is created.
StompFrame	onAbort(StompFrame request)
abstract StompFrame	onAck(StompFrame request)
StompFrame	onBegin(StompFrame frame)
StompFrame	onCommit(StompFrame request)
abstract StompFrame	onConnect(StompFrame frame)
abstract StompFrame	onDisconnect(StompFrame frame)
void	onError(ActiveMQStompException e)
abstract StompFrame	onNack(StompFrame request)
StompFrame	onSend(StompFrame frame)
abstract StompFrame	onStomp(StompFrame request)
StompFrame	onSubscribe(StompFrame request)
StompFrame	onUnknown(String command)
abstract StompFrame	onUnsubscribe(StompFrame request)
StompFrame	postprocess(StompFrame request)

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected StompConnection connection

decoder

protected StompDecoder decoder

scheduledExecutorService

protected final ScheduledExecutorService scheduledExecutorService

executorFactory

protected final ExecutorFactory executorFactory

Constructor Detail

VersionedStompFrameHandler

protected VersionedStompFrameHandler(StompConnection connection,
                                     ScheduledExecutorService scheduledExecutorService,
                                     ExecutorFactory executorFactory)

Method Detail

getHandler

public static VersionedStompFrameHandler getHandler(StompConnection connection,
                                                    StompVersions version,
                                                    ScheduledExecutorService scheduledExecutorService,
                                                    ExecutorFactory executorFactory)

decode

public StompFrame decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
                  throws ActiveMQStompException

Throws:

ActiveMQStompException

hasBytes

public boolean hasBytes()

getDecoder

public StompDecoder getDecoder()

handleFrame

public StompFrame handleFrame(StompFrame request)

onConnect

public abstract StompFrame onConnect(StompFrame frame)

onDisconnect

public abstract StompFrame onDisconnect(StompFrame frame)

onAck

public abstract StompFrame onAck(StompFrame request)

onUnsubscribe

public abstract StompFrame onUnsubscribe(StompFrame request)

onStomp

public abstract StompFrame onStomp(StompFrame request)

onNack

public abstract StompFrame onNack(StompFrame request)

createStompFrame

public abstract StompFrame createStompFrame(String command)

onUnknown

public StompFrame onUnknown(String command)

handleReceipt

public StompFrame handleReceipt(String receiptID)

onCommit

public StompFrame onCommit(StompFrame request)

onSend

public StompFrame onSend(StompFrame frame)

onBegin

public StompFrame onBegin(StompFrame frame)

onAbort

public StompFrame onAbort(StompFrame request)

onSubscribe

public StompFrame onSubscribe(StompFrame request)

postprocess

public StompFrame postprocess(StompFrame request)

createMessageFrame

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

Throws:

Exception

initDecoder

public void initDecoder(VersionedStompFrameHandler existingHandler)

this method is called when a newer version of handler is created. It should take over the state of the decoder of the existingHandler so that the decoding can be continued. For V10 handler it's never called.

Parameters:

existingHandler -

onError

public void onError(ActiveMQStompException e)