TibrvCmQueueTransport
Class
Declaration
classTibrvCmQueueTransport
: public TibrvCmTransport
TibrvCmQueueTransport(); // Create empty.
virtual ~TibrvCmQueueTransport(); // Destroy and reclaim storage.
Purpose
Coordinate a distributed queue for one-of-n delivery.
Remarks
Each TibrvCmQueueTransport object employs a TibrvTransport for network communications. The TibrvCmQueueTransport adds the accounting and coordination mechanisms needed for one-of-n delivery.
Several TibrvCmQueueTransport objects can employ one TibrvTransport, which also remains available for its own ordinary listeners and for sending ordinary messages.
The constructor creates a hollow object; TibrvCmQueueTransport::create() makes it operational. The destructor calls the destroy
method, unless the C object is already destroyed. Programs must explicitly destroy each TibrvCmQueueTransport object. Destroying a TibrvCmQueueTransport invalidates any certified listeners using that transport (while preserving their certified delivery agreements).
All members of a distributed queue must listen to exactly the same set of subjects. See Enforcing Identical Subscriptions in
.Scheduler recovery and task rescheduling are available only when the task message is a certified message (that is, a certified delivery agreement is in effect between the task sender and the distributed queue transport scheduler).
Disabled Methods
Although TibrvCmQueueTransport is a subclass of TibrvCmTransport, all methods related to sending messages are disabled in TibrvCmQueueTransport; for a list, see Disabled Methods. See also Certified Delivery Behavior in Queue Members in .