#include <StompCommandReader.h>
Inheritance diagram for activemq::connector::stomp::StompCommandReader:
Public Member Functions | |
StompCommandReader (void) | |
StompCommandReader (io::InputStream *is) | |
virtual | ~StompCommandReader (void) |
virtual transport::Command * | readCommand (void) throw ( transport::CommandIOException ) |
virtual void | setInputStream (io::InputStream *is) |
virtual io::InputStream * | getInputStream (void) |
virtual int | read (unsigned char *buffer, int count) throw ( io::IOException ) |
virtual unsigned char | readByte (void) throw ( io::IOException ) |
Private Member Functions | |
void | readStompCommand (StompFrame &frame) throw ( StompConnectorException ) |
void | readStompHeaders (StompFrame &frame) throw ( StompConnectorException ) |
int | readStompHeaderLine (void) throw ( StompConnectorException ) |
void | readStompBody (StompFrame &frame) throw ( StompConnectorException ) |
Private Attributes | |
io::InputStream * | inputStream |
std::vector< unsigned char > | buffer |
marshal::Marshaler | marshaler |
|
Deafult Constructor |
|
Constructor.
|
|
|
|
Gets the target input stream.
Implements activemq::io::Reader. |
|
Attempts to read an array of bytes from the stream.
Implements activemq::io::Reader. |
|
Attempts to read a byte from the input stream
Implements activemq::io::Reader. |
|
Reads a command from the given input stream.
Implements activemq::transport::CommandReader. |
|
Reads the Stomp Body from the Wire and store it in the frame.
|
|
Read the Stomp Command from the Frame
|
|
Reads a Stomp Header line and stores it in the buffer object
|
|
Read all the Stomp Headers for the incoming Frame
|
|
Sets the target input stream.
Implements activemq::io::Reader. |
|
Vector Object used to buffer data |
|
The target input stream. |
|
Marshaler of Stomp Commands |