![]() |
Habari STOMP Client for RabbitMQ 7.2
Object Pascal STOMP client library for RabbitMQ
|
A Connection object is a client's active connection to its provider. More...
Public Member Functions | |
TBTConnection | MakeConnection () |
A static helper method to create a new connection. | |
TBTConnection | MakeConnection (const string UserName, const string Password, const string URL) |
A static helper method to create a new connection. | |
Boolean | TransportConnected () |
Is the transport layer connected? More... | |
string | StompSessionID () |
Stomp session ID. More... | |
string | StompServerName () |
Stomp server name. More... | |
TStompProtocolVersion | StompProtocolVersion () |
Stomp protocol version of the current connection. More... | |
Stop () | |
Temporarily stops a connection's delivery of incoming messages. More... | |
ISession | CreateSession (const Boolean Transacted, const TAcknowledgementMode AcknowledgementMode) |
Creates a new session to work on this connection, specifying transacted and acknowledgeMode. More... | |
ISession | CreateSession (const TAcknowledgementMode ASessionMode) |
Creates a new session to work on this connection, specifying sessionMode. More... | |
SetDefaultClientID (const string Value) | |
Sets the default client id that the connection will use if explicitly not set with the SetClientID call. | |
SetTransformer (const IMessageTransformer Transformer) | |
Set the message transformer. | |
IMessageTransformer | GetTransformer () |
Get the message transformer. | |
Public Attributes | |
string | ClientID |
The client identifier for this connection. More... | |
Protected Member Functions | |
CheckClientIDWasManuallySpecified () | |
Ensures that the ClientID was manually specified and not auto-generated. More... | |
UnsubscribeDurable (const string Destination, const string Name) | |
Unsubscribes a durable subscription that has been created by a client. More... | |
SendHeartbeat () | |
Send a heartbeat signal (requires Stomp 1.1) | |
CheckHeartbeat () | |
Check for server heartbeat signal (requires Stomp 1.1) More... | |
Boolean | ReceiveHeartbeat (const Integer ATimeout) |
Try to receive server heartbeat. More... | |
A Connection object is a client's active connection to its provider.
A connection serves several purposes:
|
protected |
Ensures that the ClientID was manually specified and not auto-generated.
If the ClientID was not specified this method will throw an exception. This method is used to ensure that the ClientID + durableSubscriber name are used correctly.
|
protected |
Check for server heartbeat signal (requires Stomp 1.1)
ENoHeartbeat | if an expected server heartbeat was missing |
ISession TBTConnection::CreateSession | ( | const Boolean | Transacted, |
const TAcknowledgementMode | AcknowledgementMode | ||
) |
Creates a new session to work on this connection, specifying transacted and acknowledgeMode.
Transacted | - indicates whether the session is transacted |
AcknowledgementMode | - indicates whether the consumer or the client will acknowledge any messages it receives. |
ISession TBTConnection::CreateSession | ( | const TAcknowledgementMode | ASessionMode | ) |
Creates a new session to work on this connection, specifying sessionMode.
ASessionMode | - indicates whether the consumer or the client will acknowledge any messages it receives. |
|
protected |
Try to receive server heartbeat.
Requires Stomp 1.1
ATimeout | timeout |
TStompProtocolVersion TBTConnection::StompProtocolVersion | ( | ) |
Stomp protocol version of the current connection.
string TBTConnection::StompServerName | ( | ) |
Stomp server name.
string TBTConnection::StompSessionID | ( | ) |
Stomp session ID.
TBTConnection::Stop | ( | ) |
Temporarily stops a connection's delivery of incoming messages.
Delivery can be restarted using the connection's Start method.
When the connection is stopped, delivery to all the connection's message consumers is inhibited: synchronous receives block, and messages are not delivered to message listeners.
Boolean TBTConnection::TransportConnected | ( | ) |
Is the transport layer connected?
|
protected |
Unsubscribes a durable subscription that has been created by a client.
Destination | - the destination name |
Name | - the subscription name |
string TBTConnection::ClientID |
The client identifier for this connection.
Not required with RabbitMQ.