TibrvCmQueueTransport

Class

Declaration

class com.tibco.tibrv.TibrvCmQueueTransport
  extends TibrvCmTransport

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.

Programs must explicitly destroy each TibrvCmQueueTransport object. Destroying a TibrvCmQueueTransport invalidates any certified listeners using that transport (while preserving their certified delivery agreements).

Whether explicitly or implicitly, programs must destroy instances of this class. Rendezvous software keeps internal references to these objects, so the Java garbage collector does not delete them automatically.

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. These disabled methods throw an IllegalStateException; for a list, see Disabled Methods. See also Certified Delivery Behavior in Queue Members in TIBCO Rendezvous Concepts.

Method

Description

TibrvCmQueueTransport()

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.isValid() (override)

java.lang.Object.equals

java.lang.Object.getClass

java.lang.Object.hashCode

java.lang.Object.notify

java.lang.Object.notifyAll

java.lang.Object.toString

java.lang.Object.wait

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()

Constant

Description

TibrvCmQueueTransport.DEFAULT_COMPLETE_TIME

static final double 0

TibrvCmQueueTransport.DEFAULT_WORKER_WEIGHT

static final int 1

TibrvCmQueueTransport.DEFAULT_WORKER_TASKS

static final int 1

TibrvCmQueueTransport.DEFAULT_SCHEDULER_WEIGHT

static final int 1

TibrvCmQueueTransport.DEFAULT_SCHEDULER_HEARTBEAT

static final double 1.0

TibrvCmQueueTransport.DEFAULT_SCHEDULER_ACTIVATION

static final double 3.5

Related Classes

TibrvTransport

TibrvRvdTransport

TibrvCmTransport