public class StompFrameHandlerV12 extends StompFrameHandlerV11 implements FrameEventListener
Modifier and Type | Class and Description |
---|---|
protected class |
StompFrameHandlerV12.StompDecoderV12 |
StompFrameHandlerV11.StompDecoderV11
ESC_CHAR
connection, decoder
Constructor and Description |
---|
StompFrameHandlerV12(StompConnection connection) |
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
|
createPingFrame, initDecoder, onConnect, onDisconnect, onNack, onStomp, onUnsubscribe, replySent, requestAccepted
decode, getDecoder, getHandler, handleFrame, handleReceipt, hasBytes, onAbort, onBegin, onCommit, onError, onSend, onSubscribe, onUnknown, postprocess
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
replySent, requestAccepted
public StompFrameHandlerV12(StompConnection connection)
public StompFrame createStompFrame(String command)
createStompFrame
in class StompFrameHandlerV11
public StompFrame createMessageFrame(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount) throws Exception
createMessageFrame
in class VersionedStompFrameHandler
Exception
public StompFrame onAck(StompFrame request)
onAck
in class StompFrameHandlerV11
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.