org.hornetq.core.protocol.stomp.v12

Class StompFrameHandlerV12

java.lang.Object

org.hornetq.core.protocol.stomp.VersionedStompFrameHandler

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

org.hornetq.core.protocol.stomp.v12.StompFrameHandlerV12

All Implemented Interfaces:

FrameEventListener

public class StompFrameHandlerV12
extends StompFrameHandlerV11
implements FrameEventListener

Author:

Howard Gao

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StompFrameHandlerV12.StompDecoderV12

Nested classes/interfaces inherited from class org.hornetq.core.protocol.stomp.v11.StompFrameHandlerV11

StompFrameHandlerV11.StompDecoderV11

Field Summary

Fields inherited from class org.hornetq.core.protocol.stomp.v11.StompFrameHandlerV11

ESC_CHAR

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

connection, decoder

Constructor Summary

Constructors

Constructor and Description
StompFrameHandlerV12(StompConnection connection)

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.hornetq.core.protocol.stomp.v11.StompFrameHandlerV11

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

Methods inherited from class org.hornetq.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

Methods inherited from interface org.hornetq.core.protocol.stomp.FrameEventListener

replySent, requestAccepted

Constructor Detail

StompFrameHandlerV12

public StompFrameHandlerV12(StompConnection connection)

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