public class StompFrameHandlerV12 extends StompFrameHandlerV11
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
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 © 2016 The Apache Software Foundation. All rights reserved.