TBTMQTransportOpenMQ Class Reference

Stomp transport implementation for OpenMQ. More...

Inheritance diagram for TBTMQTransportOpenMQ:

Public Member Functions
	TBTMQTransportOpenMQ ()
string	GetStompDestinationName (const IDestination Destination)
	UnsubscribeDurable (const string Destination, const string Name)
	Send UNSUBSCRIBE frame for durable subscriber.
	Ack (const string MessageID, const string SubscriptionID, const string TransactionID)
	Send ACK frame.
Public Member Functions inherited from TBTAbstractTransport
	Trace (const string S)
	InternalSend (TBTMessage AMessage, const string ADest, const Boolean IsText, const Integer ASendTimeOut)
	FillCreatedMessage (const IMessage AMessage, const IStompFrame Frame)
	FillUserDefinedProperties (const IMessage AMessage, const IStompFrame Frame)
	CheckSendDestination (const string ADest)
	TBTAbstractTransport ()
string	GetStompDestinationName (const IDestination Destination)
	SendMessage (const TBTMessage AMessage, const string Dest, const Integer SendTimeOut)
IMessage	Receive ()
IMessage	Receive (const Integer Timeout)
IMessage	ReceiveNoWait ()

Protected Member Functions
	StompMessageFrameAvailable (const IStompFrame Frame)
	FillStompFrame (const TBTMessage AMessage, const IStompFrame Frame, TStompProtocolVersion StompVersion)
Boolean	IgnoreProperty (const string AKey)
	CheckNoReservedProperty (const string PropName)
TDateTime	GetExpirationHeader (const IStompFrame AFrame)
IDestination	CreateDestinationFromStompName (const string StompDestination)
Protected Member Functions inherited from TBTAbstractTransport
Boolean	IsMapTransformation (const string ATransformationId)
Boolean	IsObjectTransformation (const string ATransformationId)
TDateTime	GetExpirationHeader (const IStompFrame AFrame)
	FillStompFrame (const TBTMessage AMessage, const IStompFrame Frame, TStompProtocolVersion StompVersion)
	CheckNoReservedProperty (const string PropName)
	CheckTextMimeType (const string ContentType)
Boolean	IgnoreProperty (const string AKey)
IDestination	CreateDestinationFromStompName (const string StompDestination)
ITextMessage	CreateTextMessage (const IStompFrame Frame, TBTStompClient ATransport, const string SubscriptionID)
IBytesMessage	CreateBytesMessage (const IStompFrame Frame, TBTStompClient ATransport, const string SubscriptionID)
IMapMessage	CreateMapMessage (const IStompFrame Frame, TBTStompClient ATransport, const string SubscriptionID)
IObjectMessage	CreateObjectMessage (const IStompFrame Frame, TBTStompClient ATransport, const string SubscriptionID)
string	GetReplyTo (const IDestination ReplyTo)

Additional Inherited Members
Public Attributes inherited from TBTAbstractTransport
TOnMessageEvent	FOnMessage
string	FMapMessageTransformationId
string	FObjectMessageTransformationId
string	MapMessageTransformationId
string	ObjectMessageTransformationId
TOnMessageEvent	OnMessage
Protected Attributes inherited from TBTAbstractTransport
IMessage	CurrentMessage

Detailed Description

Stomp transport implementation for OpenMQ.

Constructor & Destructor Documentation

TBTMQTransportOpenMQ()

TBTMQTransportOpenMQ::TBTMQTransportOpenMQ

(

)

Member Function Documentation

Ack()

TBTMQTransportOpenMQ::Ack	(	const string	MessageID,
		const string	SubscriptionID,
		const string	TransactionID )

Send ACK frame.

Parameters

MessageID	value matching the message-id for the MESSAGE being acknowledged
SubscriptionID	required in STOMP 1.1, must be set to match the value of the subscription's id header
TransactionID	(optional) indicating that the message acknowledgment should be part of the named transaction

CheckNoReservedProperty()

TBTMQTransportOpenMQ::CheckNoReservedProperty ( const string PropName )

protected

CreateDestinationFromStompName()

IDestination TBTMQTransportOpenMQ::CreateDestinationFromStompName ( const string StompDestination )

protected

FillStompFrame()

TBTMQTransportOpenMQ::FillStompFrame ( const TBTMessage AMessage, const IStompFrame Frame, TStompProtocolVersion StompVersion )

protected

GetExpirationHeader()

TDateTime TBTMQTransportOpenMQ::GetExpirationHeader ( const IStompFrame AFrame )

protected

GetStompDestinationName()

string TBTMQTransportOpenMQ::GetStompDestinationName

(

const IDestination

Destination

)

IgnoreProperty()

Boolean TBTMQTransportOpenMQ::IgnoreProperty ( const string AKey )

protected

StompMessageFrameAvailable()

TBTMQTransportOpenMQ::StompMessageFrameAvailable ( const IStompFrame Frame )

protected

UnsubscribeDurable()

TBTMQTransportOpenMQ::UnsubscribeDurable	(	const string	Destination,
		const string	Name )

Send UNSUBSCRIBE frame for durable subscriber.

Parameters

Destination	destination name
Name	subscription name