Disposing a flow must not be performed in the flow callback delegate of the flow being disposed.
public interface IFlow : IDisposable, IStatsAccessible, IMessageDispatcher
Thetype exposes the following members.
Sends an acknowledgement for a message received over this flow.
This instructs the API to consider the specified ADMessageId acknowledged at the application layer. The library does not send acknowledgements immediately. It stores the state for acknowledged messages internally and acknowledges messages, in bulk, when a threshold or timer is reached.
The exact behavior of Ack() is controlled by flow property MessageAckMode:
When the transport is flow controlled (for example, the application is overwhelming the underlying tcp connection), if it is not possible for the API to block until the congestion is relieved, the call to this method will return SOLCLIENT_WOULD_BLOCK on sessions configured with SendBlocking set to false. The session event callback delegate will receive a subsequent CanSend when the congestion is relieved. On sessions configured with SendBlocking set to true, the call to this method, will block until the congestion is relieved unless this is not possible (due to to the fact that the this method is called from a callback delegate). If it's not possible to block, this method will return SOLCLIENT_FAIL with a subcode of CannotBlockInContext
In practice this occurs very rarely as most applications do not simulteously publish and receive large amounts of data on the same session. On sessions that primarily receive data, sending acknowledgements alone cannot generate enough traffic to overwhelm the tcp connection.
Clears the stats dictionary.(Inherited from IStatsAccessible.)
Creates a IDispatchTarget instance to be used in the Subscribe(IDispatchTarget, Int32, Object) and Unsubscribe(IDispatchTarget, Int32, Object) methods.(Inherited from IMessageDispatcher.)
Note: Client applications must keep IDispatchTarget object references accessible if they want to Unsubscribe from the given IMessageDispatcher, and remove already added Topic subscriptions. IDispatchTarget internal object ID constitutes a unique key. Forgetting to keep a reference to IDispatchTarget objects make subsequent Unsubscribe(IDispatchTarget, Int32, Object) calls impossible.
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.(Inherited from .)
Returns a reference to the Endpoint which this flow is bound to.
Non-durable endpoints are implicitly created after creating the flow and connecting the parent session, therefore calling this method before the parent ISession is connected will throw an OperationErrorException.
Returns the Rx Stats.(Inherited from IStatsAccessible.)
Returns a reference to the ISession that was used to create this flow.
Returns a reference to a ITopic subscription instance.
Similar to Non-durable endpoints, temporary destinations returned by this method are implicitly created after the flow is created and parent session is connected.
Returns a reference to the Transacted Sesion asociated to the Flow.
Returns the Tx Stats.(Inherited from IStatsAccessible.)
Receives a message from a specified transacted Flow. It waits until a timeout or a message is received. No wait if timeout is zero. Applications must later call .Dispose() on the received message to release it.
Settles a message in a requested way. See Also Ack(Int64).
Settle has 3 message outcome options:
The exact behavior of Settle() is controlled by flow property MessageAckMode:
Stops or closes the transport window resulting in the eventual halt of message delivery. Stopping a flow does not result in message loss. It simply "pauses" message delivery until Start() is called again.
To restart a flow after it is been stopped, clients must call Start on the stopped flow.
Adds a IDispatchTarget subscription to the given IMessageDispatcher.(Inherited from IMessageDispatcher.)
Note: In order to use this feature, the parent ISession's SessionProperties must have TopicDispatch set to true.
Removes an IDispatchTarget subscription from the given IMessageDispatcher.(Inherited from IMessageDispatcher.)
Note: To use this feature, the parent ISession's SessionProperties must have TopicDispatch set to true.