TBTMQTransportRabbitMQ Class Reference

Stomp transport implementation for RabbitMQ. More...

Inheritance diagram for TBTMQTransportRabbitMQ:

Public Member Functions
	TBTMQTransportRabbitMQ ()
string	GetStompDestinationName (const IDestination Destination)
	UnsubscribeDurable (const string Destination, const string Name)
	Send UNSUBSCRIBE frame for durable subscriber.
	UnsubscribeID (const string ID)
	Send UNSUBSCRIBE 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 RabbitMQ.

Constructor & Destructor Documentation

TBTMQTransportRabbitMQ()

TBTMQTransportRabbitMQ::TBTMQTransportRabbitMQ

(

)

Member Function Documentation

CheckNoReservedProperty()

TBTMQTransportRabbitMQ::CheckNoReservedProperty ( const string PropName )

protected

CreateDestinationFromStompName()

IDestination TBTMQTransportRabbitMQ::CreateDestinationFromStompName ( const string StompDestination )

protected

FillStompFrame()

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

protected

GetExpirationHeader()

TDateTime TBTMQTransportRabbitMQ::GetExpirationHeader ( const IStompFrame AFrame )

protected

GetStompDestinationName()

string TBTMQTransportRabbitMQ::GetStompDestinationName

(

const IDestination

Destination

)

IgnoreProperty()

Boolean TBTMQTransportRabbitMQ::IgnoreProperty ( const string AKey )

protected

StompMessageFrameAvailable()

TBTMQTransportRabbitMQ::StompMessageFrameAvailable ( const IStompFrame Frame )

protected

UnsubscribeDurable()

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

Send UNSUBSCRIBE frame for durable subscriber.

Parameters

Destination	destination name
Name	subscription name

UnsubscribeID()

TBTMQTransportRabbitMQ::UnsubscribeID

(

const string

ID

)

Send UNSUBSCRIBE frame.

Parameters

ID	Destination ID