TibrvCmQueueTransport

Class

Declaration

class TibrvCmQueueTransport : 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 TIBCO Rendezvous Concepts.

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 TIBCO Rendezvous Concepts.

Method

Description

TibrvCmQueueTransport::create()

Create a transport as a distributed queue member.

TibrvCmQueueTransport::destroy()

Destroy a distributed queue member object.

TibrvCmQueueTransport::getCompleteTime()

Extract the worker complete time limit of a distributed queue member.

TibrvCmQueueTransport::getUnassignedMessageCount()

Extract the number of unassigned task messages from a distributed queue transport.

TibrvCmQueueTransport::getWorkerWeight()

Extract the worker weight of a distributed queue member.

TibrvCmQueueTransport::getWorkerTasks()

Extract the worker task capacity of a distributed queue member.

TibrvCmQueueTransport::setCompleteTime()

Set the worker complete time limit of a distributed queue member.

TibrvCmQueueTransport::setTaskBacklogLimit...()

Set the scheduler task queue limits of a distributed queue transport.

TibrvCmQueueTransport::setWorkerWeight()

Set the worker weight of a distributed queue member.

TibrvCmQueueTransport::setWorkerTasks()

Set the worker task capacity of a distributed queue member.

 

Inherited Methods

Legal Methods

TibrvCmTransport::getName()

TibrvCmTransport::getTransport()

TibrvTransport::destroy()

TibrvTransport::isValid()

TibrvTransport::getHandle()

TibrvTransport::setDescription()

Disabled Methods

TibrvCmTransport::addListener()

TibrvCmTransport::allowListener()

TibrvCmTransport::disallowListener()

TibrvCmTransport::getDefaultTimeLimit()

TibrvCmTransport::getLedgerName()

TibrvCmTransport::getRequestOld()

TibrvCmTransport::getSyncLedger()

TibrvCmTransport::removeListener()

TibrvCmTransport::removeSendState()

TibrvCmTransport::reviewLedger()

TibrvCmTransport::send()

TibrvCmTransport::sendReply()

TibrvCmTransport::sendRequest()

TibrvCmTransport::setDefaultTimeLimit()

TibrvCmTransport::syncLedger()

TibrvTransport::createInbox()

TibrvTransport::send()

TibrvTransport::sendReply()

TibrvTransport::sendRequest()

Related Classes

TibrvTransport

TibrvNetTransport

TibrvCmTransport