activemq::connector::stomp::StompCommandReader Class Reference

#include <StompCommandReader.h>

Inheritance diagram for activemq::connector::stomp::StompCommandReader:

activemq::transport::CommandReader activemq::io::Reader List of all members.

Public Member Functions

 StompCommandReader (void)
 StompCommandReader (io::InputStream *is)
virtual ~StompCommandReader (void)
virtual transport::CommandreadCommand (void) throw ( transport::CommandIOException )
virtual void setInputStream (io::InputStream *is)
virtual io::InputStreamgetInputStream (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::InputStreaminputStream
std::vector< unsigned char > buffer
marshal::Marshaler marshaler

Constructor & Destructor Documentation

StompCommandReader::StompCommandReader void   ) 
 

Deafult Constructor

StompCommandReader::StompCommandReader io::InputStream is  ) 
 

Constructor.

Parameters:
is the target input stream.

virtual activemq::connector::stomp::StompCommandReader::~StompCommandReader void   )  [inline, virtual]
 


Member Function Documentation

virtual io::InputStream* activemq::connector::stomp::StompCommandReader::getInputStream void   )  [inline, virtual]
 

Gets the target input stream.

Returns:
Target Input Stream

Implements activemq::io::Reader.

int StompCommandReader::read unsigned char *  buffer,
int  count
throw ( io::IOException ) [virtual]
 

Attempts to read an array of bytes from the stream.

Parameters:
buffer The target byte buffer.
count The number of bytes to read.
Returns:
The number of bytes read.
Exceptions:
IOException thrown if an error occurs.

Implements activemq::io::Reader.

unsigned char StompCommandReader::readByte void   )  throw ( io::IOException ) [virtual]
 

Attempts to read a byte from the input stream

Returns:
The byte.
Exceptions:
IOException thrown if an error occurs.

Implements activemq::io::Reader.

Command * StompCommandReader::readCommand void   )  throw ( transport::CommandIOException ) [virtual]
 

Reads a command from the given input stream.

Returns:
The next command available on the stream.
Exceptions:
CommandIOException if a problem occurs during the read.

Implements activemq::transport::CommandReader.

void StompCommandReader::readStompBody StompFrame frame  )  throw ( StompConnectorException ) [private]
 

Reads the Stomp Body from the Wire and store it in the frame.

Parameters:
Stomp Frame to place data in

void StompCommandReader::readStompCommand StompFrame frame  )  throw ( StompConnectorException ) [private]
 

Read the Stomp Command from the Frame

Parameters:
reference to a Stomp Frame
Exceptions:
StompConnectorException 

int StompCommandReader::readStompHeaderLine void   )  throw ( StompConnectorException ) [private]
 

Reads a Stomp Header line and stores it in the buffer object

Returns:
number of bytes read, zero if there was a problem.
Exceptions:
StompConnectorException 

void StompCommandReader::readStompHeaders StompFrame frame  )  throw ( StompConnectorException ) [private]
 

Read all the Stomp Headers for the incoming Frame

Parameters:
Frame to place data into
Exceptions:
StompConnectorException 

virtual void activemq::connector::stomp::StompCommandReader::setInputStream io::InputStream is  )  [inline, virtual]
 

Sets the target input stream.

Parameters:
Target Input Stream

Implements activemq::io::Reader.


Member Data Documentation

std::vector<unsigned char> activemq::connector::stomp::StompCommandReader::buffer [private]
 

Vector Object used to buffer data

io::InputStream* activemq::connector::stomp::StompCommandReader::inputStream [private]
 

The target input stream.

marshal::Marshaler activemq::connector::stomp::StompCommandReader::marshaler [private]
 

Marshaler of Stomp Commands


The documentation for this class was generated from the following files:
Generated on Thu Aug 3 18:03:32 2006 for activemq-cpp by  doxygen 1.4.5