org.hornetq.core.protocol.stomp.v11

Class StompFrameHandlerV11

java.lang.Object

org.hornetq.core.protocol.stomp.VersionedStompFrameHandler

org.hornetq.core.protocol.stomp.v11.StompFrameHandlerV11

All Implemented Interfaces:

FrameEventListener

Direct Known Subclasses:

StompFrameHandlerV12

public class StompFrameHandlerV11
extends VersionedStompFrameHandler
implements FrameEventListener

Author:

Howard Gao

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StompFrameHandlerV11.StompDecoderV11

Field Summary

Fields

Modifier and Type	Field and Description
protected static char	ESC_CHAR

Fields inherited from class org.hornetq.core.protocol.stomp.VersionedStompFrameHandler

connection, decoder

Constructor Summary

Constructors

Constructor and Description
StompFrameHandlerV11(StompConnection connection)

Method Summary

Methods

Modifier and Type	Method and Description
StompFrame	createPingFrame()
StompFrame	createStompFrame(String command)
void	initDecoder(VersionedStompFrameHandler existingHandler) this method is called when a newer version of handler is created.
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 org.hornetq.core.protocol.stomp.VersionedStompFrameHandler

createMessageFrame, 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

Field Detail

ESC_CHAR

protected static final char ESC_CHAR

See Also:

Constant Field Values

Constructor Detail

StompFrameHandlerV11

public StompFrameHandlerV11(StompConnection connection)

Method Detail

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

replySent

public void replySent(StompFrame reply)

Specified by:

replySent in interface FrameEventListener

createPingFrame

public StompFrame createPingFrame()
                           throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

requestAccepted

public void requestAccepted(StompFrame request)

Specified by:

requestAccepted in interface FrameEventListener

createStompFrame

public StompFrame createStompFrame(String command)

Specified by:

createStompFrame in class VersionedStompFrameHandler

initDecoder

public void initDecoder(VersionedStompFrameHandler existingHandler)

Description copied from class: VersionedStompFrameHandler

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 get called.

Overrides:

initDecoder in class VersionedStompFrameHandler