public class StompDecoder extends Object
Constructor and Description |
---|
StompDecoder() |
Modifier and Type | Method and Description |
---|---|
StompFrame |
decode(HornetQBuffer buffer) |
boolean |
hasBytes() |
void |
init() |
void |
init(StompDecoder decoder) |
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 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 static final String CONTENT_TYPE_HEADER_NAME
public static final String CONTENT_LENGTH_HEADER_NAME
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
public boolean hasBytes()
public StompFrame decode(HornetQBuffer buffer) throws HornetQStompException
HornetQStompException
protected StompFrame parseBody() throws HornetQStompException
HornetQStompException
protected boolean parseHeaders() throws HornetQStompException
HornetQStompException
protected boolean parseCommand() throws HornetQStompException
HornetQStompException
public void throwInvalid() throws HornetQStompException
HornetQStompException
public void init()
public void resizeWorking(int newSize)
public boolean tryIncrement(int length)
public void init(StompDecoder decoder)
Copyright © 2013 JBoss, a division of Red Hat. All rights reserved.