![]() |
Habari STOMP Client for Artemis 7.2
Object Pascal STOMP client library for ActiveMQ Artemis
|
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. | |
SetMapMessageTransformationId (const string ATransformationId) | |
Set the transformation id for map messages. | |
SetObjectMessageTransformationId (const string ATransformationId) | |
Set the transformation id for object messages. | |
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... | |
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?
string TBTConnection::ClientID |
The client identifier for this connection.
The purpose of the client identifier is to associate a connection and its objects with a state maintained on behalf of the client by a provider. The only such state identified by the API is that required to support durable subscriptions.