Class StompFrameHandlerV10

java.lang.Object

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

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

All Implemented Interfaces:

FrameEventListener

public class StompFrameHandlerV10
extends VersionedStompFrameHandler
implements FrameEventListener

Field Summary

Fields inherited from class VersionedStompFrameHandler

connection, decoder, EMPTY_BODY, executorFactory, scheduledExecutorService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
StompFrame	createStompFrame(String command)
StompFrame	onAck(StompFrame request)
StompFrame	onConnect(StompFrame frame)
StompFrame	onDisconnect(StompFrame frame)
StompFrame	onNack(StompFrame request)
StompFrame	onStomp(StompFrame request)
StompFrame	onUnsubscribe(StompFrame request)
void	replySent(StompFrame reply)
void	requestAccepted(StompFrame request)

Methods inherited from class VersionedStompFrameHandler

createMessageFrame, decode, disconnect, getDecoder, getDestination, getDestination, getFailedAuthenticationResponse, getHandler, getPrefix, handleFrame, handleReceipt, hasBytes, initDecoder, 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

StompFrameHandlerV10

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

Method Details

onConnect

public StompFrame onConnect(StompFrame frame)

Specified by:

onConnect in class VersionedStompFrameHandler

onDisconnect

public StompFrame onDisconnect(StompFrame frame)

Specified by:

onDisconnect in class VersionedStompFrameHandler

onUnsubscribe

public StompFrame onUnsubscribe(StompFrame request)

Specified by:

onUnsubscribe in class VersionedStompFrameHandler

onAck

public StompFrame onAck(StompFrame request)

Specified by:

onAck in class VersionedStompFrameHandler

onStomp

public StompFrame onStomp(StompFrame request)

Specified by:

onStomp in class VersionedStompFrameHandler

onNack

public StompFrame onNack(StompFrame request)

Specified by:

onNack in class VersionedStompFrameHandler

createStompFrame

public StompFrame createStompFrame(String command)

Specified by:

createStompFrame in class VersionedStompFrameHandler

replySent

public void replySent(StompFrame reply)

Specified by:

replySent in interface FrameEventListener

requestAccepted

public void requestAccepted(StompFrame request)

Specified by:

requestAccepted in interface FrameEventListener