#include <src/main/activemq/commands/Message.h>

Inheritance diagram for activemq::wireformat::stomp::Message:

Public Member Functions
	Message ()
virtual	~Message ()
virtual unsigned char	getDataStructureType () const
	Get the DataStructure Type as defined in CommandTypes.h.
virtual Message *	cloneDataStructure () const
	Clone this obbject and return a new instance that the caller now owns, this will be an exact copy of this one.
virtual void	copyDataStructure (const DataStructure *src)
virtual std::string	toString () const
	Returns a string containing the information for this DataStructure such as its type and value of its elements.
virtual bool	equals (const DataStructure *value) const
Pointer< Message >	copy () const
	Create a Pointer based copy of this message.
virtual void	beforeMarshal (wireformat::WireFormat *wireFormat AMQCPP_UNUSED)
	Handles the marshaling of the objects properties into the internal byte array before the object is marshaled to the wire.
virtual void	afterUnmarshal (wireformat::WireFormat *wireFormat AMQCPP_UNUSED)
	Called after unmarshaling is started to cleanup the object being unmarshaled.
virtual bool	isMarshalAware () const
	Indicates that this command is aware of Marshaling, and needs to have its Marshaling methods invoked.
virtual void	setAckHandler (const Pointer< core::ActiveMQAckHandler > &handler)
	Sets the Acknowledgment Handler that this Message will use when the Acknowledge method is called.
virtual Pointer< core::ActiveMQAckHandler >	getAckHandler () const
	Gets the Acknowledgment Handler that this Message will use when the Acknowledge method is called.
void	setConnection (core::ActiveMQConnection *connection)
	Sets the ActiveMQConnection instance that this Command was created from when the session create methods are called to create a Message.
core::ActiveMQConnection *	getConnection () const
	Gets the ActiveMQConnection instance that this Command was created from when the session create methods are called to create a Message.
virtual unsigned int	getSize () const
	Returns the Size of this message in Bytes.
virtual bool	isExpired () const
	Returns if this message has expired, meaning that its Expiration time has elapsed.
virtual void	onSend ()
	Allows derived Message classes to perform tasks before a message is sent.
util::PrimitiveMap &	getMessageProperties ()
	Gets a reference to the Message's Properties object, allows the derived classes to get and set their own specific properties.
const util::PrimitiveMap &	getMessageProperties () const
bool	isReadOnlyProperties () const
	Returns if the Message Properties Are Read Only.
void	setReadOnlyProperties (bool value)
	Set the Read Only State of the Message Properties.
bool	isReadOnlyBody () const
	Returns if the Message Body is Read Only.
void	setReadOnlyBody (bool value)
	Set the Read Only State of the Message Content.
virtual const Pointer< ProducerId > &	getProducerId () const
virtual Pointer< ProducerId > &	getProducerId ()
virtual void	setProducerId (const Pointer< ProducerId > &producerId)
virtual const Pointer< ActiveMQDestination > &	getDestination () const
virtual Pointer< ActiveMQDestination > &	getDestination ()
virtual void	setDestination (const Pointer< ActiveMQDestination > &destination)
virtual const Pointer< TransactionId > &	getTransactionId () const
virtual Pointer< TransactionId > &	getTransactionId ()
virtual void	setTransactionId (const Pointer< TransactionId > &transactionId)
virtual const Pointer< ActiveMQDestination > &	getOriginalDestination () const
virtual Pointer< ActiveMQDestination > &	getOriginalDestination ()
virtual void	setOriginalDestination (const Pointer< ActiveMQDestination > &originalDestination)
virtual const Pointer< MessageId > &	getMessageId () const
virtual Pointer< MessageId > &	getMessageId ()
virtual void	setMessageId (const Pointer< MessageId > &messageId)
virtual const Pointer< TransactionId > &	getOriginalTransactionId () const
virtual Pointer< TransactionId > &	getOriginalTransactionId ()
virtual void	setOriginalTransactionId (const Pointer< TransactionId > &originalTransactionId)
virtual const std::string &	getGroupID () const
virtual std::string &	getGroupID ()
virtual void	setGroupID (const std::string &groupID)
virtual int	getGroupSequence () const
virtual void	setGroupSequence (int groupSequence)
virtual const std::string &	getCorrelationId () const
virtual std::string &	getCorrelationId ()
virtual void	setCorrelationId (const std::string &correlationId)
virtual bool	isPersistent () const
virtual void	setPersistent (bool persistent)
virtual long long	getExpiration () const
virtual void	setExpiration (long long expiration)
virtual unsigned char	getPriority () const
virtual void	setPriority (unsigned char priority)
virtual const Pointer< ActiveMQDestination > &	getReplyTo () const
virtual Pointer< ActiveMQDestination > &	getReplyTo ()
virtual void	setReplyTo (const Pointer< ActiveMQDestination > &replyTo)
virtual long long	getTimestamp () const
virtual void	setTimestamp (long long timestamp)
virtual const std::string &	getType () const
virtual std::string &	getType ()
virtual void	setType (const std::string &type)
virtual const std::vector< unsigned char > &	getContent () const
virtual std::vector< unsigned char > &	getContent ()
virtual void	setContent (const std::vector< unsigned char > &content)
virtual const std::vector< unsigned char > &	getMarshalledProperties () const
virtual std::vector< unsigned char > &	getMarshalledProperties ()
virtual void	setMarshalledProperties (const std::vector< unsigned char > &marshalledProperties)
virtual const Pointer< DataStructure > &	getDataStructure () const
virtual Pointer< DataStructure > &	getDataStructure ()
virtual void	setDataStructure (const Pointer< DataStructure > &dataStructure)
virtual const Pointer< ConsumerId > &	getTargetConsumerId () const
virtual Pointer< ConsumerId > &	getTargetConsumerId ()
virtual void	setTargetConsumerId (const Pointer< ConsumerId > &targetConsumerId)
virtual bool	isCompressed () const
virtual void	setCompressed (bool compressed)
virtual int	getRedeliveryCounter () const
virtual void	setRedeliveryCounter (int redeliveryCounter)
virtual const std::vector< decaf::lang::Pointer< BrokerId > > &	getBrokerPath () const
virtual std::vector< decaf::lang::Pointer< BrokerId > > &	getBrokerPath ()
virtual void	setBrokerPath (const std::vector< decaf::lang::Pointer< BrokerId > > &brokerPath)
virtual long long	getArrival () const
virtual void	setArrival (long long arrival)
virtual const std::string &	getUserID () const
virtual std::string &	getUserID ()
virtual void	setUserID (const std::string &userID)
virtual bool	isRecievedByDFBridge () const
virtual void	setRecievedByDFBridge (bool recievedByDFBridge)
virtual bool	isDroppable () const
virtual void	setDroppable (bool droppable)
virtual const std::vector< decaf::lang::Pointer< BrokerId > > &	getCluster () const
virtual std::vector< decaf::lang::Pointer< BrokerId > > &	getCluster ()
virtual void	setCluster (const std::vector< decaf::lang::Pointer< BrokerId > > &cluster)
virtual long long	getBrokerInTime () const
virtual void	setBrokerInTime (long long brokerInTime)
virtual long long	getBrokerOutTime () const
virtual void	setBrokerOutTime (long long brokerOutTime)
virtual bool	isJMSXGroupFirstForConsumer () const
virtual void	setJMSXGroupFirstForConsumer (bool jMSXGroupFirstForConsumer)
virtual bool	isMessage () const
virtual Pointer< Command >	visit (activemq::state::CommandVisitor *visitor)
	Allows a Visitor to visit this command and return a response to the command based on the command type being visited.
Public Member Functions inherited from activemq::commands::BaseCommand
	BaseCommand ()
virtual	~BaseCommand ()
virtual void	setCommandId (int id)
	Sets the Command Id of this Message.
virtual int	getCommandId () const
	Gets the Command Id of this Message.
virtual void	setResponseRequired (const bool required)
	Set if this Message requires a Response.
virtual bool	isResponseRequired () const
	Is a Response required for this Command.
virtual void	copyDataStructure (const DataStructure *src)
	Copy the contents of the passed object into this objects members, overwriting any existing data.
virtual bool	equals (const DataStructure *value) const
	Compares the DataStructure passed in to this one, and returns if they are equivalent.
virtual bool	isBrokerInfo () const
virtual bool	isControlCommand () const
virtual bool	isConnectionControl () const
virtual bool	isConnectionError () const
virtual bool	isConnectionInfo () const
virtual bool	isConsumerInfo () const
virtual bool	isConsumerControl () const
virtual bool	isDestinationInfo () const
virtual bool	isFlushCommand () const
virtual bool	isMessageAck () const
virtual bool	isMessagePull () const
virtual bool	isKeepAliveInfo () const
virtual bool	isMessageDispatch () const
virtual bool	isMessageDispatchNotification () const
virtual bool	isProducerAck () const
virtual bool	isProducerInfo () const
virtual bool	isResponse () const
virtual bool	isRemoveInfo () const
virtual bool	isRemoveSubscriptionInfo () const
virtual bool	isReplayCommand () const
virtual bool	isSessionInfo () const
virtual bool	isShutdownInfo () const
virtual bool	isTransactionInfo () const
virtual bool	isWireFormatInfo () const
Public Member Functions inherited from activemq::commands::Command
virtual	~Command ()
Public Member Functions inherited from activemq::commands::BaseDataStructure
virtual	~BaseDataStructure ()
virtual void	afterMarshal (wireformat::WireFormat *wireFormat AMQCPP_UNUSED)
virtual void	beforeUnmarshal (wireformat::WireFormat *wireFormat AMQCPP_UNUSED)
virtual void	setMarshaledForm (wireformat::WireFormat *wireFormat AMQCPP_UNUSED, const std::vector< char > &data AMQCPP_UNUSED)
virtual std::vector< unsigned char >	getMarshaledForm (wireformat::WireFormat *wireFormat AMQCPP_UNUSED)
virtual void	copyDataStructure (const DataStructure *src AMQCPP_UNUSED)
virtual bool	equals (const DataStructure *value AMQCPP_UNUSED) const
Public Member Functions inherited from activemq::commands::DataStructure
virtual	~DataStructure ()
Public Member Functions inherited from activemq::wireformat::MarshalAware
virtual	~MarshalAware ()
virtual void	beforeMarshal (WireFormat *wireFormat)=0
	Called before marshaling is started to prepare the object to be marshaled.
virtual void	afterMarshal (WireFormat *wireFormat)=0
	Called after marshaling is started to cleanup the object being marshaled.
virtual void	beforeUnmarshal (WireFormat *wireFormat)=0
	Called before unmarshaling is started to prepare the object to be unmarshaled.
virtual void	afterUnmarshal (WireFormat *wireFormat)=0
	Called after unmarshaling is started to cleanup the object being unmarshaled.
virtual void	setMarshaledForm (WireFormat *wireFormat, const std::vector< char > &data)=0
	Called to set the data to this object that will contain the objects marshaled form.
virtual std::vector< unsigned char >	getMarshaledForm (WireFormat *wireFormat)=0
	Called to get the data to this object that will contain the objects marshaled form.

Static Public Attributes
static const unsigned char	ID_MESSAGE = 0

Protected Attributes
Pointer< ProducerId >	producerId
Pointer< ActiveMQDestination >	destination
Pointer< TransactionId >	transactionId
Pointer< ActiveMQDestination >	originalDestination
Pointer< MessageId >	messageId
Pointer< TransactionId >	originalTransactionId
std::string	groupID
int	groupSequence
std::string	correlationId
bool	persistent
long long	expiration
unsigned char	priority
Pointer< ActiveMQDestination >	replyTo
long long	timestamp
std::string	type
std::vector< unsigned char >	content
std::vector< unsigned char >	marshalledProperties
Pointer< DataStructure >	dataStructure
Pointer< ConsumerId >	targetConsumerId
bool	compressed
int	redeliveryCounter
std::vector< decaf::lang::Pointer< BrokerId > >	brokerPath
long long	arrival
std::string	userID
bool	recievedByDFBridge
bool	droppable
std::vector< decaf::lang::Pointer< BrokerId > >	cluster
long long	brokerInTime
long long	brokerOutTime
bool	jMSXGroupFirstForConsumer
core::ActiveMQConnection *	connection

Static Protected Attributes
static const unsigned int	DEFAULT_MESSAGE_SIZE = 1024

Constructor & Destructor Documentation

◆ Message()

activemq::commands::Message::Message ( )

◆ ~Message()

virtual activemq::commands::Message::~Message ( )

virtual

Member Function Documentation

◆ afterUnmarshal()

virtual void activemq::commands::Message::afterUnmarshal ( wireformat::WireFormat *wireFormat AMQCPP_UNUSED )

virtual

Called after unmarshaling is started to cleanup the object being unmarshaled.

Parameters

wireFormat - the wireformat object to control unmarshaling

Reimplemented from activemq::commands::BaseDataStructure.

◆ beforeMarshal()

virtual void activemq::commands::Message::beforeMarshal ( wireformat::WireFormat *wireFormat AMQCPP_UNUSED )

virtual

Handles the marshaling of the objects properties into the internal byte array before the object is marshaled to the wire.

Parameters

wireFormat - the wireformat controller

Reimplemented from activemq::commands::BaseDataStructure.

◆ cloneDataStructure()

virtual Message * activemq::commands::Message::cloneDataStructure ( ) const

virtual

Clone this obbject and return a new instance that the caller now owns, this will be an exact copy of this one.

Returns: new copy of this object.

Implements activemq::commands::DataStructure.

◆ copy()

Pointer< Message > activemq::commands::Message::copy ( ) const

inline

Create a Pointer based copy of this message.

Useful for chaining a clone operation with other operation such as casting to a cms Message type.

Pointer<cms::Message> cmsMsg = message->copy().dynamic_cast<cms::Message>();

Returns: a Pointer<Message> which is a duplicate of this object.

◆ copyDataStructure()

virtual void activemq::commands::Message::copyDataStructure ( const DataStructure * src )

virtual

◆ equals()

virtual bool activemq::commands::Message::equals ( const DataStructure * value ) const

virtual

◆ getAckHandler()

virtual Pointer< core::ActiveMQAckHandler > activemq::commands::Message::getAckHandler ( ) const

inlinevirtual

Gets the Acknowledgment Handler that this Message will use when the Acknowledge method is called.

Returns: handler ActiveMQAckHandler to call or NULL if not set

◆ getArrival()

virtual long long activemq::commands::Message::getArrival ( ) const

virtual

◆ getBrokerInTime()

virtual long long activemq::commands::Message::getBrokerInTime ( ) const

virtual

◆ getBrokerOutTime()

virtual long long activemq::commands::Message::getBrokerOutTime ( ) const

virtual

◆ getBrokerPath() [1/2]

virtual std::vector< decaf::lang::Pointer< BrokerId > > & activemq::commands::Message::getBrokerPath ( )

virtual

◆ getBrokerPath() [2/2]

virtual const std::vector< decaf::lang::Pointer< BrokerId > > & activemq::commands::Message::getBrokerPath ( ) const

virtual

◆ getCluster() [1/2]

virtual std::vector< decaf::lang::Pointer< BrokerId > > & activemq::commands::Message::getCluster ( )

virtual

◆ getCluster() [2/2]

virtual const std::vector< decaf::lang::Pointer< BrokerId > > & activemq::commands::Message::getCluster ( ) const

virtual

◆ getConnection()

core::ActiveMQConnection * activemq::commands::Message::getConnection ( ) const

inline

Gets the ActiveMQConnection instance that this Command was created from when the session create methods are called to create a Message.

Returns: the ActiveMQConnection parent for this Message or NULL if not set.

◆ getContent() [1/2]

virtual std::vector< unsigned char > & activemq::commands::Message::getContent ( )

virtual

◆ getContent() [2/2]

virtual const std::vector< unsigned char > & activemq::commands::Message::getContent ( ) const

virtual

◆ getCorrelationId() [1/2]

virtual std::string & activemq::commands::Message::getCorrelationId ( )

virtual

◆ getCorrelationId() [2/2]

virtual const std::string & activemq::commands::Message::getCorrelationId ( ) const

virtual

◆ getDataStructure() [1/2]

virtual Pointer< DataStructure > & activemq::commands::Message::getDataStructure ( )

virtual

◆ getDataStructure() [2/2]

virtual const Pointer< DataStructure > & activemq::commands::Message::getDataStructure ( ) const

virtual

◆ getDataStructureType()

virtual unsigned char activemq::commands::Message::getDataStructureType ( ) const

virtual

Get the DataStructure Type as defined in CommandTypes.h.

Returns: The type of the data structure

Implements activemq::commands::DataStructure.

◆ getDestination() [1/2]

virtual Pointer< ActiveMQDestination > & activemq::commands::Message::getDestination ( )

virtual

◆ getDestination() [2/2]

virtual const Pointer< ActiveMQDestination > & activemq::commands::Message::getDestination ( ) const

virtual

◆ getExpiration()

virtual long long activemq::commands::Message::getExpiration ( ) const

virtual

◆ getGroupID() [1/2]

virtual std::string & activemq::commands::Message::getGroupID ( )

virtual

◆ getGroupID() [2/2]

virtual const std::string & activemq::commands::Message::getGroupID ( ) const

virtual

◆ getGroupSequence()

virtual int activemq::commands::Message::getGroupSequence ( ) const

virtual

◆ getMarshalledProperties() [1/2]

virtual std::vector< unsigned char > & activemq::commands::Message::getMarshalledProperties ( )

virtual

◆ getMarshalledProperties() [2/2]

virtual const std::vector< unsigned char > & activemq::commands::Message::getMarshalledProperties ( ) const

virtual

◆ getMessageId() [1/2]

virtual Pointer< MessageId > & activemq::commands::Message::getMessageId ( )

virtual

◆ getMessageId() [2/2]

virtual const Pointer< MessageId > & activemq::commands::Message::getMessageId ( ) const

virtual

◆ getMessageProperties() [1/2]

util::PrimitiveMap & activemq::commands::Message::getMessageProperties ( )

inline

Gets a reference to the Message's Properties object, allows the derived classes to get and set their own specific properties.

Returns: a reference to the Primitive Map that holds message properties.

◆ getMessageProperties() [2/2]

const util::PrimitiveMap & activemq::commands::Message::getMessageProperties ( ) const

inline

◆ getOriginalDestination() [1/2]

virtual Pointer< ActiveMQDestination > & activemq::commands::Message::getOriginalDestination ( )

virtual

◆ getOriginalDestination() [2/2]

virtual const Pointer< ActiveMQDestination > & activemq::commands::Message::getOriginalDestination ( ) const

virtual

◆ getOriginalTransactionId() [1/2]

virtual Pointer< TransactionId > & activemq::commands::Message::getOriginalTransactionId ( )

virtual

◆ getOriginalTransactionId() [2/2]

virtual const Pointer< TransactionId > & activemq::commands::Message::getOriginalTransactionId ( ) const

virtual

◆ getPriority()

virtual unsigned char activemq::commands::Message::getPriority ( ) const

virtual

◆ getProducerId() [1/2]

virtual Pointer< ProducerId > & activemq::commands::Message::getProducerId ( )

virtual

◆ getProducerId() [2/2]

virtual const Pointer< ProducerId > & activemq::commands::Message::getProducerId ( ) const

virtual

◆ getRedeliveryCounter()

virtual int activemq::commands::Message::getRedeliveryCounter ( ) const

virtual

◆ getReplyTo() [1/2]

virtual Pointer< ActiveMQDestination > & activemq::commands::Message::getReplyTo ( )

virtual

◆ getReplyTo() [2/2]

virtual const Pointer< ActiveMQDestination > & activemq::commands::Message::getReplyTo ( ) const

virtual

◆ getSize()

virtual unsigned int activemq::commands::Message::getSize ( ) const

virtual

Returns the Size of this message in Bytes.

Returns: number of bytes this message equates to.

◆ getTargetConsumerId() [1/2]

virtual Pointer< ConsumerId > & activemq::commands::Message::getTargetConsumerId ( )

virtual

◆ getTargetConsumerId() [2/2]

virtual const Pointer< ConsumerId > & activemq::commands::Message::getTargetConsumerId ( ) const

virtual

◆ getTimestamp()

virtual long long activemq::commands::Message::getTimestamp ( ) const

virtual

◆ getTransactionId() [1/2]

virtual Pointer< TransactionId > & activemq::commands::Message::getTransactionId ( )

virtual

◆ getTransactionId() [2/2]

virtual const Pointer< TransactionId > & activemq::commands::Message::getTransactionId ( ) const

virtual

◆ getType() [1/2]

virtual std::string & activemq::commands::Message::getType ( )

virtual

◆ getType() [2/2]

virtual const std::string & activemq::commands::Message::getType ( ) const

virtual

◆ getUserID() [1/2]

virtual std::string & activemq::commands::Message::getUserID ( )

virtual

◆ getUserID() [2/2]

virtual const std::string & activemq::commands::Message::getUserID ( ) const

virtual

◆ isCompressed()

virtual bool activemq::commands::Message::isCompressed ( ) const

virtual

◆ isDroppable()

virtual bool activemq::commands::Message::isDroppable ( ) const

virtual

◆ isExpired()

virtual bool activemq::commands::Message::isExpired ( ) const

virtual

Returns if this message has expired, meaning that its Expiration time has elapsed.

Returns: true if message is expired.

◆ isJMSXGroupFirstForConsumer()

virtual bool activemq::commands::Message::isJMSXGroupFirstForConsumer ( ) const

virtual

◆ isMarshalAware()

virtual bool activemq::commands::Message::isMarshalAware ( ) const

inlinevirtual

Indicates that this command is aware of Marshaling, and needs to have its Marshaling methods invoked.

Returns: boolean indicating desire to be in marshaling stages

Reimplemented from activemq::commands::BaseDataStructure.

◆ isMessage()

virtual bool activemq::commands::Message::isMessage ( ) const

inlinevirtual

Returns: an answer of true to the isMessage() query.

Reimplemented from activemq::commands::BaseCommand.

◆ isPersistent()

virtual bool activemq::commands::Message::isPersistent ( ) const

virtual

◆ isReadOnlyBody()

bool activemq::commands::Message::isReadOnlyBody ( ) const

inline

Returns if the Message Body is Read Only.

Returns: true if Message Content is Read Only.

◆ isReadOnlyProperties()

bool activemq::commands::Message::isReadOnlyProperties ( ) const

inline

Returns if the Message Properties Are Read Only.

Returns: true if Message Properties are Read Only.

◆ isRecievedByDFBridge()

virtual bool activemq::commands::Message::isRecievedByDFBridge ( ) const

virtual

◆ onSend()

virtual void activemq::commands::Message::onSend ( )

inlinevirtual

Allows derived Message classes to perform tasks before a message is sent.

◆ setAckHandler()

virtual void activemq::commands::Message::setAckHandler ( const Pointer< core::ActiveMQAckHandler > & handler )

inlinevirtual

Sets the Acknowledgment Handler that this Message will use when the Acknowledge method is called.

Parameters

handler ActiveMQAckHandler to call

◆ setArrival()

virtual void activemq::commands::Message::setArrival ( long long arrival )

virtual

◆ setBrokerInTime()

virtual void activemq::commands::Message::setBrokerInTime ( long long brokerInTime )

virtual

◆ setBrokerOutTime()

virtual void activemq::commands::Message::setBrokerOutTime ( long long brokerOutTime )

virtual

◆ setBrokerPath()

virtual void activemq::commands::Message::setBrokerPath ( const std::vector< decaf::lang::Pointer< BrokerId > > & brokerPath )

virtual

◆ setCluster()

virtual void activemq::commands::Message::setCluster ( const std::vector< decaf::lang::Pointer< BrokerId > > & cluster )

virtual

◆ setCompressed()

virtual void activemq::commands::Message::setCompressed ( bool compressed )

virtual

◆ setConnection()

void activemq::commands::Message::setConnection ( core::ActiveMQConnection * connection )

inline

Sets the ActiveMQConnection instance that this Command was created from when the session create methods are called to create a Message.

Parameters

handler ActiveMQConnection parent for this message

◆ setContent()

virtual void activemq::commands::Message::setContent ( const std::vector< unsigned char > & content )

virtual

◆ setCorrelationId()

virtual void activemq::commands::Message::setCorrelationId ( const std::string & correlationId )

virtual

◆ setDataStructure()

virtual void activemq::commands::Message::setDataStructure ( const Pointer< DataStructure > & dataStructure )

virtual

◆ setDestination()

virtual void activemq::commands::Message::setDestination ( const Pointer< ActiveMQDestination > & destination )

virtual

◆ setDroppable()

virtual void activemq::commands::Message::setDroppable ( bool droppable )

virtual

◆ setExpiration()

virtual void activemq::commands::Message::setExpiration ( long long expiration )

virtual

◆ setGroupID()

virtual void activemq::commands::Message::setGroupID ( const std::string & groupID )

virtual

◆ setGroupSequence()

virtual void activemq::commands::Message::setGroupSequence ( int groupSequence )

virtual

◆ setJMSXGroupFirstForConsumer()

virtual void activemq::commands::Message::setJMSXGroupFirstForConsumer ( bool jMSXGroupFirstForConsumer )

virtual

◆ setMarshalledProperties()

virtual void activemq::commands::Message::setMarshalledProperties ( const std::vector< unsigned char > & marshalledProperties )

virtual

◆ setMessageId()

virtual void activemq::commands::Message::setMessageId ( const Pointer< MessageId > & messageId )

virtual

◆ setOriginalDestination()

virtual void activemq::commands::Message::setOriginalDestination ( const Pointer< ActiveMQDestination > & originalDestination )

virtual

◆ setOriginalTransactionId()

virtual void activemq::commands::Message::setOriginalTransactionId ( const Pointer< TransactionId > & originalTransactionId )

virtual

◆ setPersistent()

virtual void activemq::commands::Message::setPersistent ( bool persistent )

virtual

◆ setPriority()

virtual void activemq::commands::Message::setPriority ( unsigned char priority )

virtual

◆ setProducerId()

virtual void activemq::commands::Message::setProducerId ( const Pointer< ProducerId > & producerId )

virtual

◆ setReadOnlyBody()

void activemq::commands::Message::setReadOnlyBody ( bool value )

inline

Set the Read Only State of the Message Content.

Parameters

value - true if Content should be read only.

◆ setReadOnlyProperties()

void activemq::commands::Message::setReadOnlyProperties ( bool value )

inline

Set the Read Only State of the Message Properties.

Parameters

value - true if Properties should be read only.

◆ setRecievedByDFBridge()

virtual void activemq::commands::Message::setRecievedByDFBridge ( bool recievedByDFBridge )

virtual

◆ setRedeliveryCounter()

virtual void activemq::commands::Message::setRedeliveryCounter ( int redeliveryCounter )

virtual

◆ setReplyTo()

virtual void activemq::commands::Message::setReplyTo ( const Pointer< ActiveMQDestination > & replyTo )

virtual

◆ setTargetConsumerId()

virtual void activemq::commands::Message::setTargetConsumerId ( const Pointer< ConsumerId > & targetConsumerId )

virtual

◆ setTimestamp()

virtual void activemq::commands::Message::setTimestamp ( long long timestamp )

virtual

◆ setTransactionId()

virtual void activemq::commands::Message::setTransactionId ( const Pointer< TransactionId > & transactionId )

virtual

◆ setType()

virtual void activemq::commands::Message::setType ( const std::string & type )

virtual

◆ setUserID()

virtual void activemq::commands::Message::setUserID ( const std::string & userID )

virtual

◆ toString()

virtual std::string activemq::commands::Message::toString ( ) const

virtual

Returns a string containing the information for this DataStructure such as its type and value of its elements.

Returns: formatted string useful for debugging.

Reimplemented from activemq::commands::BaseCommand.

◆ visit()

virtual Pointer< Command > activemq::commands::Message::visit ( activemq::state::CommandVisitor * visitor )

virtual

Allows a Visitor to visit this command and return a response to the command based on the command type being visited.

The command will call the proper processXXX method in the visitor.

Returns: a Response to the visitor being called or NULL if no response.

Implements activemq::commands::Command.

Field Documentation

◆ arrival

long long activemq::commands::Message::arrival

protected

◆ brokerInTime

long long activemq::commands::Message::brokerInTime

protected

◆ brokerOutTime

long long activemq::commands::Message::brokerOutTime

protected

◆ brokerPath

std::vector< decaf::lang::Pointer<BrokerId> > activemq::commands::Message::brokerPath

protected

◆ cluster

std::vector< decaf::lang::Pointer<BrokerId> > activemq::commands::Message::cluster

protected

◆ compressed

bool activemq::commands::Message::compressed

protected

◆ connection

core::ActiveMQConnection* activemq::commands::Message::connection

protected

◆ content

std::vector<unsigned char> activemq::commands::Message::content

protected

◆ correlationId

std::string activemq::commands::Message::correlationId

protected

◆ dataStructure

Pointer<DataStructure> activemq::commands::Message::dataStructure

protected

◆ DEFAULT_MESSAGE_SIZE

const unsigned int activemq::commands::Message::DEFAULT_MESSAGE_SIZE = 1024

staticprotected

◆ destination

Pointer<ActiveMQDestination> activemq::commands::Message::destination

protected

◆ droppable

bool activemq::commands::Message::droppable

protected

◆ expiration

long long activemq::commands::Message::expiration

protected

◆ groupID

std::string activemq::commands::Message::groupID

protected

◆ groupSequence

int activemq::commands::Message::groupSequence

protected

◆ ID_MESSAGE

const unsigned char activemq::commands::Message::ID_MESSAGE = 0

static

◆ jMSXGroupFirstForConsumer

bool activemq::commands::Message::jMSXGroupFirstForConsumer

protected

◆ marshalledProperties

std::vector<unsigned char> activemq::commands::Message::marshalledProperties

protected

◆ messageId

Pointer<MessageId> activemq::commands::Message::messageId

protected

◆ originalDestination

Pointer<ActiveMQDestination> activemq::commands::Message::originalDestination

protected

◆ originalTransactionId

Pointer<TransactionId> activemq::commands::Message::originalTransactionId

protected

◆ persistent

bool activemq::commands::Message::persistent

protected

◆ priority

unsigned char activemq::commands::Message::priority

protected

◆ producerId

Pointer<ProducerId> activemq::commands::Message::producerId

protected

◆ recievedByDFBridge

bool activemq::commands::Message::recievedByDFBridge

protected

◆ redeliveryCounter

int activemq::commands::Message::redeliveryCounter

protected

◆ replyTo

Pointer<ActiveMQDestination> activemq::commands::Message::replyTo

protected

◆ targetConsumerId

Pointer<ConsumerId> activemq::commands::Message::targetConsumerId

protected

◆ timestamp

long long activemq::commands::Message::timestamp

protected

◆ transactionId

Pointer<TransactionId> activemq::commands::Message::transactionId

protected

◆ type

std::string activemq::commands::Message::type

protected

◆ userID

std::string activemq::commands::Message::userID

protected

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

src/main/activemq/commands/Message.h

Public Member Functions

Static Public Attributes

Protected Attributes

Static Protected Attributes

Constructor & Destructor Documentation

◆ Message()

◆ ~Message()

Member Function Documentation

◆ afterUnmarshal()

◆ beforeMarshal()

◆ cloneDataStructure()

◆ copy()

◆ copyDataStructure()

◆ equals()

◆ getAckHandler()

◆ getArrival()

◆ getBrokerInTime()

◆ getBrokerOutTime()

◆ getBrokerPath() [1/2]

◆ getBrokerPath() [2/2]

◆ getCluster() [1/2]

◆ getCluster() [2/2]

◆ getConnection()

◆ getContent() [1/2]

◆ getContent() [2/2]

◆ getCorrelationId() [1/2]

◆ getCorrelationId() [2/2]

◆ getDataStructure() [1/2]

◆ getDataStructure() [2/2]

◆ getDataStructureType()

◆ getDestination() [1/2]

◆ getDestination() [2/2]

◆ getExpiration()

◆ getGroupID() [1/2]

◆ getGroupID() [2/2]

◆ getGroupSequence()

◆ getMarshalledProperties() [1/2]

◆ getMarshalledProperties() [2/2]

◆ getMessageId() [1/2]

◆ getMessageId() [2/2]

◆ getMessageProperties() [1/2]

◆ getMessageProperties() [2/2]

◆ getOriginalDestination() [1/2]

◆ getOriginalDestination() [2/2]

◆ getOriginalTransactionId() [1/2]

◆ getOriginalTransactionId() [2/2]

◆ getPriority()

◆ getProducerId() [1/2]

◆ getProducerId() [2/2]

◆ getRedeliveryCounter()

◆ getReplyTo() [1/2]

◆ getReplyTo() [2/2]

◆ getSize()

◆ getTargetConsumerId() [1/2]

◆ getTargetConsumerId() [2/2]

◆ getTimestamp()

◆ getTransactionId() [1/2]

◆ getTransactionId() [2/2]

◆ getType() [1/2]

◆ getType() [2/2]

◆ getUserID() [1/2]

◆ getUserID() [2/2]

◆ isCompressed()

◆ isDroppable()

◆ isExpired()

◆ isJMSXGroupFirstForConsumer()

◆ isMarshalAware()

◆ isMessage()

◆ isPersistent()

◆ isReadOnlyBody()

◆ isReadOnlyProperties()

◆ isRecievedByDFBridge()

◆ onSend()

◆ setAckHandler()

◆ setArrival()

◆ setBrokerInTime()

◆ setBrokerOutTime()

◆ setBrokerPath()

◆ setCluster()

◆ setCompressed()