activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller Class Reference

Base class for all Marshallers that marshal DataStructures to and from the wire using the OpenWire protocol. More...

#include <src/main/activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.h>

Inheritance diagram for activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller:

[legend]

Public Member Functions
virtual	~BaseDataStreamMarshaller ()
virtual int	tightMarshal1 (OpenWireFormat *format AMQCPP_UNUSED, commands::DataStructure *command AMQCPP_UNUSED, utils::BooleanStream *bs AMQCPP_UNUSED)
	Tight Marhsal to the given stream.
virtual void	tightMarshal2 (OpenWireFormat *format AMQCPP_UNUSED, commands::DataStructure *command AMQCPP_UNUSED, decaf::io::DataOutputStream *ds AMQCPP_UNUSED, utils::BooleanStream *bs AMQCPP_UNUSED)
	Tight Marshal to the given stream.
virtual void	tightUnmarshal (OpenWireFormat *format AMQCPP_UNUSED, commands::DataStructure *command AMQCPP_UNUSED, decaf::io::DataInputStream *dis AMQCPP_UNUSED, utils::BooleanStream *bs AMQCPP_UNUSED)
	Tight Un-Marshal to the given stream.
virtual void	looseMarshal (OpenWireFormat *format AMQCPP_UNUSED, commands::DataStructure *command AMQCPP_UNUSED, decaf::io::DataOutputStream *ds AMQCPP_UNUSED)
	Tight Marshal to the given stream.
virtual void	looseUnmarshal (OpenWireFormat *format AMQCPP_UNUSED, commands::DataStructure *command AMQCPP_UNUSED, decaf::io::DataInputStream *dis AMQCPP_UNUSED)
	Loose Un-Marshal to the given stream.
Static Public Member Functions
static std::string	toString (const commands::MessageId *id)
	Converts the object to a String.
static std::string	toString (const commands::ProducerId *id)
	Converts the object to a String.
static std::string	toString (const commands::TransactionId *txnId)
	Converts the given transaction ID into a String.
static std::string	toHexFromBytes (const std::vector< unsigned char > &data)
	given an array of bytes, convert that array to a Hexidecimal coded string that represents that data.
Protected Member Functions
virtual commands::DataStructure *	tightUnmarshalCachedObject (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Tight Unmarshal the cached object.
virtual int	tightMarshalCachedObject1 (OpenWireFormat *wireFormat, commands::DataStructure *data, utils::BooleanStream *bs)
	Tightly marshals the passed DataStructure based object to the passed BooleanStream returning the size of the data marshaled.
virtual void	tightMarshalCachedObject2 (OpenWireFormat *wireFormat, commands::DataStructure *data, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tightly marshals the passed DataStructure based object to the passed streams returning nothing.
virtual void	looseMarshalCachedObject (OpenWireFormat *wireFormat, commands::DataStructure *data, decaf::io::DataOutputStream *dataOut)
	Loosely marshals the passed DataStructure based object to the passed stream returning nothing.
virtual commands::DataStructure *	looseUnmarshalCachedObject (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn)
	Loose Unmarshal the cached object.
virtual int	tightMarshalNestedObject1 (OpenWireFormat *wireFormat, commands::DataStructure *object, utils::BooleanStream *bs)
	Tightly marshals the passed DataStructure based object to the passed BooleanStream returning the size of the data marshaled.
virtual void	tightMarshalNestedObject2 (OpenWireFormat *wireFormat, commands::DataStructure *object, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tightly marshals the passed DataStructure based object to the passed streams returning nothing.
virtual commands::DataStructure *	tightUnmarshalNestedObject (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Tight Unmarshal the nested object.
virtual commands::DataStructure *	looseUnmarshalNestedObject (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn)
	Loose Unmarshal the nested object.
virtual void	looseMarshalNestedObject (OpenWireFormat *wireFormat, commands::DataStructure *object, decaf::io::DataOutputStream *dataOut)
	Loose marshall the nested object.
virtual std::string	tightUnmarshalString (decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Performs Tight Unmarshaling of String Objects.
virtual int	tightMarshalString1 (const std::string &value, utils::BooleanStream *bs)
	Tight Marshals the String to a Booleans Stream Object, returns the marshaled size.
virtual void	tightMarshalString2 (const std::string &value, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tight Marshals the passed string to the streams passed.
virtual void	looseMarshalString (const std::string value, decaf::io::DataOutputStream *dataOut)
	Loose Marshal the String to the DataOuputStream passed.
virtual std::string	looseUnmarshalString (decaf::io::DataInputStream *dataIn)
	Loose Un-Marshal the String to the DataOuputStream passed.
virtual int	tightMarshalLong1 (OpenWireFormat *wireFormat, long long value, utils::BooleanStream *bs)
	Tightly marshal the long long to the BooleanStream passed.
virtual void	tightMarshalLong2 (OpenWireFormat *wireFormat, long long value, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tightly marshal the long long to the Streams passed.
virtual long long	tightUnmarshalLong (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Tight marshal the long long type.
virtual void	looseMarshalLong (OpenWireFormat *wireFormat, long long value, decaf::io::DataOutputStream *dataOut)
	Tightly marshal the long long to the BooleanStream passed.
virtual long long	looseUnmarshalLong (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn)
	Loose marshal the long long type.
virtual std::vector< unsigned char >	tightUnmarshalByteArray (decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Tight Unmarshal an array of char.
virtual std::vector< unsigned char >	looseUnmarshalByteArray (decaf::io::DataInputStream *dataIn)
	Loose Unmarshal an array of char.
virtual std::vector< unsigned char >	tightUnmarshalConstByteArray (decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs, int size)
	Tight Unmarshal a fixed size array from that data input stream and return an stl vector of char as the resultant.
virtual std::vector< unsigned char >	looseUnmarshalConstByteArray (decaf::io::DataInputStream *dataIn, int size)
	Tight Unmarshal a fixed size array from that data input stream and return an stl vector of char as the resultant.
virtual commands::DataStructure *	tightUnmarshalBrokerError (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn, utils::BooleanStream *bs)
	Tight Unarshall the Error object.
virtual int	tightMarshalBrokerError1 (OpenWireFormat *wireFormat, commands::DataStructure *data, utils::BooleanStream *bs)
	Tight Marshal the Error object.
virtual void	tightMarshalBrokerError2 (OpenWireFormat *wireFormat, commands::DataStructure *data, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tight Marshal the Error object.
virtual commands::DataStructure *	looseUnmarshalBrokerError (OpenWireFormat *wireFormat, decaf::io::DataInputStream *dataIn)
	Loose Unarshal the Error object.
virtual void	looseMarshalBrokerError (OpenWireFormat *wireFormat, commands::DataStructure *data, decaf::io::DataOutputStream *dataOut)
	Tight Marshal the Error object.
template<typename T >
int	tightMarshalObjectArray1 (OpenWireFormat *wireFormat, std::vector< T > objects, utils::BooleanStream *bs)
	Tightly Marshal an array of DataStructure objects to the provided boolean stream, and return the size that the tight marshalling is going to take.
template<typename T >
void	tightMarshalObjectArray2 (OpenWireFormat *wireFormat, std::vector< T > objects, decaf::io::DataOutputStream *dataOut, utils::BooleanStream *bs)
	Tightly Marshal an array of DataStructure objects to the provided boolean stream and data output stream.
template<typename T >
void	looseMarshalObjectArray (OpenWireFormat *wireFormat, std::vector< T > objects, decaf::io::DataOutputStream *dataOut)
	Loosely Marshal an array of DataStructure objects to the provided boolean stream and data output stream.
virtual std::string	readAsciiString (decaf::io::DataInputStream *dataIn)
	Given an DataInputStream read a know ASCII formatted string from the input and return that string.

---

Detailed Description

Base class for all Marshallers that marshal DataStructures to and from the wire using the OpenWire protocol.

Since:

2.0

---

Constructor & Destructor Documentation

virtual activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::~BaseDataStreamMarshaller

(

)

[inline, virtual]

---

Member Function Documentation

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshal	(	OpenWireFormat *format	AMQCPP_UNUSED,
		commands::DataStructure *command	AMQCPP_UNUSED,
		decaf::io::DataOutputStream *ds	AMQCPP_UNUSED
	)			[inline, virtual]

Tight Marshal to the given stream.

Parameters:

	format	- The OpenwireFormat properties
	command	- the object to Marshal
	ds	- DataOutputStream to marshal to

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalBrokerError	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		decaf::io::DataOutputStream *	dataOut
	)			[protected, virtual]

Tight Marshal the Error object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- Error to Marshal
	dataOut	- stream to write marshalled data to

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalCachedObject	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		decaf::io::DataOutputStream *	dataOut
	)			[protected, virtual]

Loosely marshals the passed DataStructure based object to the passed stream returning nothing.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- DataStructure Object Pointer to marshal
	dataOut	- stream to write marshaled data to

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalLong	(	OpenWireFormat *	wireFormat,
		long long	value,
		decaf::io::DataOutputStream *	dataOut
	)			[protected, virtual]

Tightly marshal the long long to the BooleanStream passed.

Parameters:

	wireFormat	- The OpenwireFormat properties
	value	- long long to marshal
	dataOut	- DataOutputStream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalNestedObject	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	object,
		decaf::io::DataOutputStream *	dataOut
	)			[protected, virtual]

Loose marshall the nested object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	object	- DataStructure Object Pointer to marshal
	dataOut	- stream to write marshaled data to

Exceptions:

IOException

if an error occurs.

template<typename T >

void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalObjectArray	(	OpenWireFormat *	wireFormat,
		std::vector< T >	objects,
		decaf::io::DataOutputStream *	dataOut
	)			[inline, protected]

Loosely Marshal an array of DataStructure objects to the provided boolean stream and data output stream.

Parameters:

	wireFormat	- The OpenwireFormat properties
	objects	- array of DataStructure object pointers.
	dataOut	- stream to write marshalled data to

Returns:

size of the marshalled data

Exceptions:

IOException

if an error occurs.

References AMQ_CATCH_EXCEPTION_CONVERT, AMQ_CATCH_RETHROW, AMQ_CATCHALL_THROW, decaf::io::DataOutputStream::writeBoolean(), and decaf::io::DataOutputStream::writeShort().

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseMarshalString	(	const std::string	value,
		decaf::io::DataOutputStream *	dataOut
	)			[protected, virtual]

Loose Marshal the String to the DataOuputStream passed.

Parameters:

	value	- string to marshal
	dataOut	- stream to write marshaled form to

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshal	(	OpenWireFormat *format	AMQCPP_UNUSED,
		commands::DataStructure *command	AMQCPP_UNUSED,
		decaf::io::DataInputStream *dis	AMQCPP_UNUSED
	)			[inline, virtual]

Loose Un-Marshal to the given stream.

Parameters:

	format	- The OpenwireFormat properties
	command	- the object to Un-Marshal
	dis	- the DataInputStream to Un-Marshal from

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalBrokerError	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn
	)			[protected, virtual]

Loose Unarshal the Error object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshalled form from

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::vector<unsigned char> activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalByteArray

(

decaf::io::DataInputStream *

dataIn

)

[protected, virtual]

Loose Unmarshal an array of char.

Parameters:

dataIn

- the DataInputStream to Un-Marshal from

Returns:

the unmarshalled vector of chars.

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalCachedObject	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn
	)			[protected, virtual]

Loose Unmarshal the cached object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::vector<unsigned char> activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalConstByteArray	(	decaf::io::DataInputStream *	dataIn,
		int	size
	)			[protected, virtual]

Tight Unmarshal a fixed size array from that data input stream and return an stl vector of char as the resultant.

Parameters:

	dataIn	- the DataInputStream to Un-Marshal from
	size	- size of the const array to unmarshal

Returns:

the unmarshaled vector of chars.

Exceptions:

IOException

if an error occurs.

virtual long long activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalLong	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn
	)			[protected, virtual]

Loose marshal the long long type.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from

Returns:

the unmarshaled long long

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalNestedObject	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn
	)			[protected, virtual]

Loose Unmarshal the nested object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::looseUnmarshalString

(

decaf::io::DataInputStream *

dataIn

)

[protected, virtual]

Loose Un-Marshal the String to the DataOuputStream passed.

Parameters:

dataIn

- stream to read marshaled form from

Returns:

the unmarshaled string

Exceptions:

IOException

if an error occurs.

virtual std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::readAsciiString

(

decaf::io::DataInputStream *

dataIn

)

[protected, virtual]

Given an DataInputStream read a know ASCII formatted string from the input and return that string.

Parameters:

dataIn

- DataInputStream to read from

Returns:

string value read from stream

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshal1	(	OpenWireFormat *format	AMQCPP_UNUSED,
		commands::DataStructure *command	AMQCPP_UNUSED,
		utils::BooleanStream *bs	AMQCPP_UNUSED
	)			[inline, virtual]

Tight Marhsal to the given stream.

Parameters:

	format	- The OpenwireFormat properties
	command	- the object to Marshal
	bs	- boolean stream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshal2	(	OpenWireFormat *format	AMQCPP_UNUSED,
		commands::DataStructure *command	AMQCPP_UNUSED,
		decaf::io::DataOutputStream *ds	AMQCPP_UNUSED,
		utils::BooleanStream *bs	AMQCPP_UNUSED
	)			[inline, virtual]

Tight Marshal to the given stream.

Parameters:

	format	- The OpenwireFormat properties
	command	- the object to Marshal
	ds	- the DataOutputStream to Marshal to
	bs	- boolean stream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalBrokerError1	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Marshal the Error object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- Error to Marshal
	bs	- boolean stream to marshal to.

Returns:

size of the marshalled data

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalBrokerError2	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Marshal the Error object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- Error to Marshal
	dataOut	- stream to write marshalled data to
	bs	- boolean stream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalCachedObject1	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshals the passed DataStructure based object to the passed BooleanStream returning the size of the data marshaled.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- DataStructure Object Pointer to marshal
	bs	- boolean stream to marshal to.

Returns:

size of data written.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalCachedObject2	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	data,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshals the passed DataStructure based object to the passed streams returning nothing.

Parameters:

	wireFormat	- The OpenwireFormat properties
	data	- DataStructure Object Pointer to marshal
	bs	- boolean stream to marshal to.
	dataOut	- stream to write marshaled data to

Exceptions:

IOException

if an error occurs.

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalLong1	(	OpenWireFormat *	wireFormat,
		long long	value,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshal the long long to the BooleanStream passed.

Parameters:

	wireFormat	- The OpenwireFormat properties
	value	- long long to marshal
	bs	- boolean stream to marshal to.

Returns:

size of data written.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalLong2	(	OpenWireFormat *	wireFormat,
		long long	value,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshal the long long to the Streams passed.

Parameters:

	wireFormat	- The OpenwireFormat properties
	value	- long long to marshal
	dataOut	- stream to write marshaled form to
	bs	- boolean stream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalNestedObject1	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	object,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshals the passed DataStructure based object to the passed BooleanStream returning the size of the data marshaled.

Parameters:

	wireFormat	- The OpenwireFormat properties
	object	- DataStructure Object Pointer to marshal
	bs	- boolean stream to marshal to.

Returns:

size of data written.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalNestedObject2	(	OpenWireFormat *	wireFormat,
		commands::DataStructure *	object,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tightly marshals the passed DataStructure based object to the passed streams returning nothing.

Parameters:

	wireFormat	- The OpenwireFormat properties
	object	- DataStructure Object Pointer to marshal
	bs	- boolean stream to marshal to.
	dataOut	- stream to write marshaled data to

Exceptions:

IOException

if an error occurs.

template<typename T >

int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalObjectArray1	(	OpenWireFormat *	wireFormat,
		std::vector< T >	objects,
		utils::BooleanStream *	bs
	)			[inline, protected]

Tightly Marshal an array of DataStructure objects to the provided boolean stream, and return the size that the tight marshalling is going to take.

Parameters:

	wireFormat	- The OpenwireFormat properties
	objects	- array of DataStructure object pointers.
	bs	- boolean stream to marshal to.

Returns:

size of the marshalled data

Exceptions:

IOException

if an error occurs.

References AMQ_CATCH_EXCEPTION_CONVERT, AMQ_CATCH_RETHROW, AMQ_CATCHALL_THROW, and activemq::wireformat::openwire::utils::BooleanStream::writeBoolean().

template<typename T >

void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalObjectArray2	(	OpenWireFormat *	wireFormat,
		std::vector< T >	objects,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[inline, protected]

Tightly Marshal an array of DataStructure objects to the provided boolean stream and data output stream.

Parameters:

	wireFormat	- The OpenwireFormat properties
	objects	- array of DataStructure object pointers.
	dataOut	- stream to write marshalled data to
	bs	- boolean stream to marshal to.

Returns:

size of the marshalled data

Exceptions:

IOException

if an error occurs.

References AMQ_CATCH_EXCEPTION_CONVERT, AMQ_CATCH_RETHROW, AMQ_CATCHALL_THROW, activemq::wireformat::openwire::utils::BooleanStream::readBoolean(), and decaf::io::DataOutputStream::writeShort().

virtual int activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalString1	(	const std::string &	value,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Marshals the String to a Booleans Stream Object, returns the marshaled size.

Parameters:

	value	- string to marshal
	bs	- BooleanStream to use.

Returns:

size of marshaled string.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightMarshalString2	(	const std::string &	value,
		decaf::io::DataOutputStream *	dataOut,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Marshals the passed string to the streams passed.

Parameters:

	value	- string to marshal
	dataOut	- the DataOutputStream to Marshal to
	bs	- boolean stream to marshal to.

Exceptions:

IOException

if an error occurs.

virtual void activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshal	(	OpenWireFormat *format	AMQCPP_UNUSED,
		commands::DataStructure *command	AMQCPP_UNUSED,
		decaf::io::DataInputStream *dis	AMQCPP_UNUSED,
		utils::BooleanStream *bs	AMQCPP_UNUSED
	)			[inline, virtual]

Tight Un-Marshal to the given stream.

Parameters:

	format	- The OpenwireFormat properties
	command	- the object to Un-Marshal
	dis	- the DataInputStream to Un-Marshal from
	bs	- boolean stream to Un-Marshal from.

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalBrokerError	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Unarshall the Error object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshalled form from
	bs	- boolean stream to marshal to.

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::vector<unsigned char> activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalByteArray	(	decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Unmarshal an array of char.

Parameters:

	dataIn	- the DataInputStream to Un-Marshal from
	bs	- boolean stream to unmarshal from.

Returns:

the unmarshaled vector of chars.

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalCachedObject	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Unmarshal the cached object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from
	bs	- boolean stream to marshal to.

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::vector<unsigned char> activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalConstByteArray	(	decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs,
		int	size
	)			[protected, virtual]

Tight Unmarshal a fixed size array from that data input stream and return an stl vector of char as the resultant.

Parameters:

	dataIn	- the DataInputStream to Un-Marshal from
	bs	- boolean stream to unmarshal from.
	size	- size of the const array to unmarshal

Returns:

the unmarshaled vector of chars.

Exceptions:

IOException

if an error occurs.

virtual long long activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalLong	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight marshal the long long type.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from
	bs	- boolean stream to marshal to.

Returns:

the unmarshaled long long

Exceptions:

IOException

if an error occurs.

virtual commands::DataStructure* activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalNestedObject	(	OpenWireFormat *	wireFormat,
		decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Tight Unmarshal the nested object.

Parameters:

	wireFormat	- The OpenwireFormat properties
	dataIn	- stream to read marshaled form from
	bs	- boolean stream to marshal to.

Returns:

pointer to a new DataStructure Object

Exceptions:

IOException

if an error occurs.

virtual std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::tightUnmarshalString	(	decaf::io::DataInputStream *	dataIn,
		utils::BooleanStream *	bs
	)			[protected, virtual]

Performs Tight Unmarshaling of String Objects.

Parameters:

	dataIn	- the DataInputStream to Un-Marshal from
	bs	- boolean stream to unmarshal from.

Returns:

the unmarshaled string.

Exceptions:

IOException

if an error occurs.

static std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::toHexFromBytes

(

const std::vector< unsigned char > &

data

)

[static]

given an array of bytes, convert that array to a Hexidecimal coded string that represents that data.

Parameters:

data

- unsigned char data array pointer

Returns:

a string coded in hex that represents the data

static std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::toString

(

const commands::TransactionId *

txnId

)

[static]

Converts the given transaction ID into a String.

Parameters:

txnId

- TransactionId poitner

Returns:

string representation of the id

static std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::toString

(

const commands::ProducerId *

id

)

[static]

Converts the object to a String.

Parameters:

id

- ProducerId pointer

Returns:

string representing the id

static std::string activemq::wireformat::openwire::marshal::BaseDataStreamMarshaller::toString

(

const commands::MessageId *

id

)

[static]

Converts the object to a String.

Parameters:

id

- MessageId pointer

Returns:

string representing the id

Referenced by activemq::commands::ActiveMQMessageTemplate< cms::ObjectMessage >::getCMSMessageID().

---

The documentation for this class was generated from the following file:

• src/main/activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.h