TBTAbstractCommAdapterMQ Class Reference

Inheritance diagram for TBTAbstractCommAdapterMQ:

Public Member Functions
IStompFrame	ReadFrame (Integer ATimeOut)
Public Member Functions inherited from TBTAbstractCommAdapter
	TBTAbstractCommAdapter ()
	~TBTAbstractCommAdapter ()
string	AdapterName ()
	Name of the communication adapter.
	ReadOneMessage ()
	ReadOneMessage (const Integer TimeOut, const Boolean TimeOutException=False)
	ReadOneMessageNoWait ()
IStompFrame	ReadFrame (Integer ATimeOut)
	ProcessFrame (const IStompFrame AStompFrame)
	SendHeartbeat ()
	CheckHeartbeat ()
Boolean	ReceiveHeartbeat (Integer ATimeOut)
	Try to receive server heartbeat.
Boolean	ServerExpectsHeartBeat ()
Boolean	ServerSendsHeartBeats ()
	StoreHeartbeatTimestamp ()
Boolean	IsMinStompVersion (const TStompProtocolVersion AVersion)
	CheckMinStompVersion (const TStompProtocolVersion AVersion)

Additional Inherited Members
Public Attributes inherited from TBTAbstractCommAdapter
Integer	ConnectTimeOut
	Connect time out (in milliseconds).
Boolean	ConnectTimeOutSpecifiedManually
TStompProtocolVersion	StompVersion
Integer	ClientHeartBeatInterval
Integer	ServerHeartBeatInterval
IURI	URI
Protected Member Functions inherited from TBTAbstractCommAdapter
	SetConnectTimeOut (Integer Value)
Integer	GetConnectTimeOut ()
TStompProtocolVersion	GetStompVersion ()
	SetStompVersion (TStompProtocolVersion Value)
	SetURI (const IURI Value)
IURI	GetURI ()
TBTDataAvailableEvent	GetOnDataAvailable ()
	SetOnDataAvailable (TBTDataAvailableEvent Value)
Boolean	GetConnectTimeOutSpecifiedManually ()
	SetConnectTimeOutSpecifiedManually (const Boolean Value)
TNotifyEvent	GetOnConnected ()
	SetOnConnected (TNotifyEvent Value)
	SetOnAfterTransportConnected (TNotifyEvent Value)
TNotifyEvent	GetOnAfterTransportConnected ()
	SetClientHeartBeatInterval (Integer Value)
Integer	GetClientHeartBeatInterval ()
	SetServerHeartBeatInterval (Integer Value)
Integer	GetServerHeartBeatInterval ()
	AssertServerSendsHeartBeats ()
	AssertTransportConnected ()
	AssertIsTrailingNull (Byte B)
	AssertIsTrailingLf (Byte B)
	CheckValidTimeOut (Integer ATimeOut)
string	ReadFirstHeaderLineSkippingHeartbeats (Integer ATimeOut)
string	ReadHeaderLine (Integer ATimeOut)
IStompFrame	ReadStompHeader (Integer ATimeOut)
RawByteString	ReadMessageBodyTerminated ()
RawByteString	ReadMessageBodyWithLength (Integer ALength)
	ReadTrailingNull ()
	ReadTrailingLf ()
Integer	StompCONNECTEDFrameTimeout ()
	Connect ()
	Establish a STOMP connection.
	AfterSocketConnected ()
Boolean	SupportsProtocol (const string ProtocolName)
	StompDisconnect ()
Boolean	TransportConnected ()
	StompTransmit (const RawByteString Value, const Integer SendTimeOut=TCP_DEFAULT_SEND_TIMEOUT)
	CheckTransportConnected ()
	TryConsumeHeartBeats (Integer ATimeOut)
	Consume heart-beats.
	BeforeConsumeHeartBeats (Integer ATimeOut)
string	GetURIParam (const string AKey)
	Get parameter AKey of the connection URI params.
Protected Attributes inherited from TBTAbstractCommAdapter
Boolean	FTransportConnected
IStompDecoder	StompDecoder
Boolean	HeartbeatSeen
TBTDataAvailableEvent	OnDataAvailable
TNotifyEvent	OnConnected
Integer	DataTimeout

Member Function Documentation

ReadFrame()

IStompFrame TBTAbstractCommAdapterMQ::ReadFrame

(

Integer

ATimeOut

)