public class StompDecoder extends Object
Constructor and Description |
---|
StompDecoder(VersionedStompFrameHandler handler) |
Modifier and Type | Method and Description |
---|---|
StompFrame |
decode(ActiveMQBuffer buffer) |
boolean |
hasBytes() |
void |
init() |
void |
init(StompDecoder decoder)
This should be overridden by subclasses.
|
protected StompFrame |
parseBody() |
protected boolean |
parseCommand() |
protected boolean |
parseHeaders() |
void |
resizeWorking(int newSize) |
void |
throwInvalid() |
boolean |
tryIncrement(int length) |
public static final boolean TRIM_LEADING_HEADER_VALUE_WHITESPACE
public static final String COMMAND_ABORT
public static final int COMMAND_ABORT_LENGTH
public static final String COMMAND_ACK
public static final int COMMAND_ACK_LENGTH
public static final String COMMAND_NACK
public static final int COMMAND_NACK_LENGTH
public static final String COMMAND_BEGIN
public static final int COMMAND_BEGIN_LENGTH
public static final String COMMAND_COMMIT
public static final int COMMAND_COMMIT_LENGTH
public static final String COMMAND_CONNECT
public static final int COMMAND_CONNECT_LENGTH
public static final String COMMAND_DISCONNECT
public static final int COMMAND_DISCONNECT_LENGTH
public static final String COMMAND_SEND
public static final int COMMAND_SEND_LENGTH
public static final String COMMAND_STOMP
public static final int COMMAND_STOMP_LENGTH
public static final String COMMAND_SUBSCRIBE
public static final int COMMAND_SUBSCRIBE_LENGTH
public static final String COMMAND_UNSUBSCRIBE
public static final int COMMAND_UNSUBSCRIBE_LENGTH
public static final String COMMAND_CONNECTED
public static final int COMMAND_CONNECTED_LENGTH
public static final String COMMAND_MESSAGE
public static final int COMMAND_MESSAGE_LENGTH
public static final String COMMAND_ERROR
public static final int COMMAND_ERROR_LENGTH
public static final String COMMAND_RECEIPT
public static final int COMMAND_RECEIPT_LENGTH
public static final byte A
public static final byte B
public static final byte C
public static final byte c
public static final byte D
public static final byte E
public static final byte T
public static final byte M
public static final byte S
public static final byte R
public static final byte U
public static final byte N
public static final byte LN
public static final byte RT
public static final byte HEADER_SEPARATOR
public static final byte NEW_LINE
public static final byte CR
public static final byte SPACE
public static final byte TAB
public byte[] workingBuffer
public int pos
public int data
public String command
public boolean readingHeaders
public boolean headerValueWhitespace
public boolean inHeaderName
public String headerName
public boolean whiteSpaceOnly
public int contentLength
public String contentType
public int bodyStart
protected int eolLen
protected final VersionedStompFrameHandler handler
public StompDecoder(VersionedStompFrameHandler handler)
public boolean hasBytes()
public StompFrame decode(ActiveMQBuffer buffer) throws ActiveMQStompException
ActiveMQStompException
protected StompFrame parseBody() throws ActiveMQStompException
ActiveMQStompException
protected boolean parseHeaders() throws ActiveMQStompException
ActiveMQStompException
protected boolean parseCommand() throws ActiveMQStompException
ActiveMQStompException
public void throwInvalid() throws ActiveMQStompException
ActiveMQStompException
public void init()
public void resizeWorking(int newSize)
public boolean tryIncrement(int length)
public void init(StompDecoder decoder)
Copyright © 2016 The Apache Software Foundation. All rights reserved.