RoutingMessage Class Reference

#include <RoutingMessage.h>

Public Types
enum	REQUEST_TYPE { Batch, SingleMessage }

Public Member Functions
	RoutingMessage ()
	RoutingMessage (const string &source)
	RoutingMessage (const string &tableName, const string &messageId, bool delayRead)
	RoutingMessage (const string &tableName, const string &messageId, RoutingMessage(*messageProviderCallback)()=NULL, bool fastpath=false)
	RoutingMessage (const RoutingMessage &source)
RoutingMessage &	operator= (const RoutingMessage &source)
	~RoutingMessage ()
void	Read ()
bool	isReply ()
bool	isAck ()
bool	isNack ()
string	ToString (bool payloadEncoded=false)
string	ToString (const string &payload)
void	DelayTransform (const string &transform, const string &sessionCode, const unsigned int sequence)
string	getDelayedTransform () const
string	getDelayedTransformSessCode () const
void	setBatchSequence (const unsigned long sequence)
unsigned long	getBatchSequence () const
string	getOriginalMessageType () const
void	setOutputSession (const string &osession)
string	getOutputSession () const
void	setBatchTotalCount (const unsigned long batchcount)
unsigned long	getBatchTotalCount () const
void	setBatchTotalAmount (const string &amount)
string	getBatchTotalAmount () const
RoutingMessageOptions::MESSAGE_OPTIONS	getMessageOptions () const
void	setMessageOptions (const RoutingMessageOptions::MESSAGE_OPTIONS options)
void	setMessageOption (const RoutingMessageOptions::MESSAGE_OPTIONS option)
string	getMessageId () const
void	setMessageId (const string &messageId)
string	getCorrelationId () const
string	getSessionId () const
string	getBatchId () const
void	setBatchId (const string &value)
unsigned long	getPriority () const
void	setPriority (const unsigned long value)
string	getUserId () const
void	setUserId (const int userId)
void	setCorrelationId (const string &correlationId)
RoutingAggregationCode	getAggregationCode ()
const RoutingAggregationCode &	getFeedback () const
void	setFeedback (const RoutingAggregationCode &feedback)
string	getFeedbackString () const
void	setFeedback (const string &feedback)
long	getRoutingSequence () const
void	setRoutingSequence (const long value)
bool	isHeld () const
void	setHeld (const bool value)
bool	isBulk () const
void	setBulk (const bool value)
bool	isVirtual () const
void	setVirtual (const bool value)
bool	isDuplicate () const
string	getRequestorService () const
void	setRequestorService (const string &value)
string	getOriginalRequestorService () const
void	setOriginalRequestorService (const string &value)
string	getResponderService () const
void	setResponderService (const string &value)
string	getTableName () const
void	setTableName (const string &value)
REQUEST_TYPE	getRequestType () const
void	setRequestType (const REQUEST_TYPE value)
const RoutingMessagePayload *const	getPayload () const
RoutingMessagePayload *	getPayload ()
void	setPayload (const string &payload)
RoutingMessageEvaluator *	getPayloadEvaluator (const bool forceReload=false)
void	destroyPayloadEvaluator ()
void	setFastpath (const bool fastpath)
bool	getFastpath () const
string	getOriginalPayload (const RoutingMessagePayload::PayloadFormat format=RoutingMessagePayload::AUTO) const
void	setDelayedReplyId (const string &idValue)
string	getDelayedReplyId () const

Static Public Member Functions
static RoutingMessage::REQUEST_TYPE	ParseRequestType (const string &request)
static string	ToString (REQUEST_TYPE reqType)

Private Attributes
string	m_MessageId
string	m_BatchId
string	m_CorrelationId
string	m_SessionId
string	m_UserId
unsigned long	m_Priority
unsigned long	m_BatchSequence
unsigned long	m_BatchCount
string	m_BatchAmount
string	m_OriginalMessageType
long	m_RoutingSequence
bool	m_HoldStatus
string	m_DelayedTransform
string	m_DelayedTransformSessionCode
string	m_DelayedReplyId
RoutingAggregationCode	m_Feedback
RoutingMessageOptions::MESSAGE_OPTIONS	m_MessageOptions
string	m_RequestorService
string	m_ResponderService
string	m_OriginalRequestorService
REQUEST_TYPE	m_RequestType
bool	m_Fastpath
bool	m_Bulk
bool	m_Virtual
string	m_TableName
RoutingMessagePayload *	m_Payload
RoutingMessageEvaluator *	m_PayloadEvaluator

Friends
ostream &	operator<< (ostream &os, const RoutingMessage &except)

Member Enumeration Documentation

enum RoutingMessage::REQUEST_TYPE

Enumerator
Batch
SingleMessage

Constructor & Destructor Documentation

RoutingMessage::RoutingMessage

(

)

RoutingMessage::RoutingMessage

(

const string &

source

)

RoutingMessage::RoutingMessage	(	const string &	tableName,
		const string &	messageId,
		bool	delayRead
	)

RoutingMessage::RoutingMessage	(	const string &	tableName,
		const string &	messageId,
		RoutingMessage(*)()	messageProviderCallback = NULL,
		bool	fastpath = false
	)

RoutingMessage::RoutingMessage

(

const RoutingMessage &

source

)

RoutingMessage::~RoutingMessage

(

)

Member Function Documentation

void RoutingMessage::DelayTransform	(	const string &	transform,
		const string &	sessionCode,
		const unsigned int	sequence
	)

void RoutingMessage::destroyPayloadEvaluator

(

)

RoutingAggregationCode RoutingMessage::getAggregationCode

(

)

string RoutingMessage::getBatchId ( ) const

inline

unsigned long RoutingMessage::getBatchSequence ( ) const

inline

string RoutingMessage::getBatchTotalAmount ( ) const

inline

unsigned long RoutingMessage::getBatchTotalCount ( ) const

inline

string RoutingMessage::getCorrelationId ( ) const

inline

string RoutingMessage::getDelayedReplyId ( ) const

inline

string RoutingMessage::getDelayedTransform ( ) const

inline

string RoutingMessage::getDelayedTransformSessCode ( ) const

inline

bool RoutingMessage::getFastpath ( ) const

inline

const RoutingAggregationCode& RoutingMessage::getFeedback ( ) const

inline

string RoutingMessage::getFeedbackString

(

)

const

string RoutingMessage::getMessageId ( ) const

inline

RoutingMessageOptions::MESSAGE_OPTIONS RoutingMessage::getMessageOptions ( ) const

inline

string RoutingMessage::getOriginalMessageType ( ) const

inline

string RoutingMessage::getOriginalPayload

(

const RoutingMessagePayload::PayloadFormat

format = RoutingMessagePayload::AUTO

)

const

string RoutingMessage::getOriginalRequestorService ( ) const

inline

string RoutingMessage::getOutputSession ( ) const

inline

const RoutingMessagePayload* const RoutingMessage::getPayload ( ) const

inline

RoutingMessagePayload* RoutingMessage::getPayload ( )

inline

RoutingMessageEvaluator * RoutingMessage::getPayloadEvaluator

(

const bool

forceReload = false

)

unsigned long RoutingMessage::getPriority ( ) const

inline

string RoutingMessage::getRequestorService ( ) const

inline

REQUEST_TYPE RoutingMessage::getRequestType ( ) const

inline

string RoutingMessage::getResponderService ( ) const

inline

long RoutingMessage::getRoutingSequence ( ) const

inline

string RoutingMessage::getSessionId ( ) const

inline

string RoutingMessage::getTableName ( ) const

inline

string RoutingMessage::getUserId ( ) const

inline

bool RoutingMessage::isAck

(

)

bool RoutingMessage::isBulk ( ) const

inline

bool RoutingMessage::isDuplicate

(

)

const

bool RoutingMessage::isHeld ( ) const

inline

bool RoutingMessage::isNack

(

)

bool RoutingMessage::isReply

(

)

bool RoutingMessage::isVirtual ( ) const

inline

RoutingMessage & RoutingMessage::operator=

(

const RoutingMessage &

source

)

RoutingMessage::REQUEST_TYPE RoutingMessage::ParseRequestType ( const string &  request )

static

void RoutingMessage::Read

(

)

void RoutingMessage::setBatchId ( const string &  value )

inline

void RoutingMessage::setBatchSequence ( const unsigned long  sequence )

inline

void RoutingMessage::setBatchTotalAmount ( const string &  amount )

inline

void RoutingMessage::setBatchTotalCount ( const unsigned long  batchcount )

inline

void RoutingMessage::setBulk ( const bool  value )

inline

void RoutingMessage::setCorrelationId ( const string &  correlationId )

inline

void RoutingMessage::setDelayedReplyId ( const string &  idValue )

inline

void RoutingMessage::setFastpath ( const bool  fastpath )

inline

void RoutingMessage::setFeedback ( const RoutingAggregationCode &  feedback )

inline

void RoutingMessage::setFeedback

(

const string &

feedback

)

void RoutingMessage::setHeld ( const bool  value )

inline

void RoutingMessage::setMessageId ( const string &  messageId )

inline

void RoutingMessage::setMessageOption ( const RoutingMessageOptions::MESSAGE_OPTIONS  option )

inline

void RoutingMessage::setMessageOptions ( const RoutingMessageOptions::MESSAGE_OPTIONS  options )

inline

void RoutingMessage::setOriginalRequestorService ( const string &  value )

inline

void RoutingMessage::setOutputSession ( const string &  osession )

inline

void RoutingMessage::setPayload

(

const string &

payload

)

void RoutingMessage::setPriority ( const unsigned long  value )

inline

void RoutingMessage::setRequestorService ( const string &  value )

inline

void RoutingMessage::setRequestType ( const REQUEST_TYPE  value )

inline

void RoutingMessage::setResponderService ( const string &  value )

inline

void RoutingMessage::setRoutingSequence ( const long  value )

inline

void RoutingMessage::setTableName ( const string &  value )

inline

void RoutingMessage::setUserId ( const int  userId )

inline

void RoutingMessage::setVirtual ( const bool  value )

inline

string RoutingMessage::ToString

(

bool

payloadEncoded = false

)

string RoutingMessage::ToString

(

const string &

payload

)

string RoutingMessage::ToString ( REQUEST_TYPE  reqType )

static

Friends And Related Function Documentation

ostream& operator<< ( ostream &  os, const RoutingMessage &  except  )

friend

Member Data Documentation

string RoutingMessage::m_BatchAmount

private

unsigned long RoutingMessage::m_BatchCount

private

string RoutingMessage::m_BatchId

private

unsigned long RoutingMessage::m_BatchSequence

private

bool RoutingMessage::m_Bulk

private

string RoutingMessage::m_CorrelationId

private

string RoutingMessage::m_DelayedReplyId

private

string RoutingMessage::m_DelayedTransform

private

string RoutingMessage::m_DelayedTransformSessionCode

private

bool RoutingMessage::m_Fastpath

private

RoutingAggregationCode RoutingMessage::m_Feedback

private

bool RoutingMessage::m_HoldStatus

private

string RoutingMessage::m_MessageId

private

RoutingMessageOptions::MESSAGE_OPTIONS RoutingMessage::m_MessageOptions

private

string RoutingMessage::m_OriginalMessageType

private

string RoutingMessage::m_OriginalRequestorService

private

RoutingMessagePayload* RoutingMessage::m_Payload

private

RoutingMessageEvaluator* RoutingMessage::m_PayloadEvaluator

private

unsigned long RoutingMessage::m_Priority

private

string RoutingMessage::m_RequestorService

private

REQUEST_TYPE RoutingMessage::m_RequestType

private

string RoutingMessage::m_ResponderService

private

long RoutingMessage::m_RoutingSequence

private

string RoutingMessage::m_SessionId

private

string RoutingMessage::m_TableName

private

string RoutingMessage::m_UserId

private

bool RoutingMessage::m_Virtual

private

---

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

• RoutingMessage.h
• RoutingMessage.cpp