TibrvCmTransport

Class

Declaration

class com.tibco.tibrv.TibrvCmTransport
  extends TibrvTransport

Purpose

A certified delivery transport object implements the CM delivery protocol for messages.

Remarks

Each certified delivery transport employs a TibrvTransport for network communications. The TibrvCmTransport adds the accounting mechanisms needed for delivery tracking and certified delivery.

Several TibrvCmTransport objects can employ a TibrvTransport, which also remains available for its own ordinary listeners and for sending ordinary messages. Destroying this TibrvTransport causes the TibrvCmTransport to destroy itself as well (along with all its listeners, while preserving their certified delivery agreements).

Destroying a certified delivery transport object invalidates subsequent certified send calls on that object, invalidates any certified listeners using that transport (while preserving the certified delivery agreements of those listeners).

Programs must explicitly destroy each certified delivery transport object. Rendezvous software keeps internal references to these objects, so the Java garbage collector does not delete them automatically.

Method

Description

TibrvCmTransport()

Create a transport for certified delivery.

TibrvCmTransport.addListener()

Pre-register an anticipated listener.

TibrvCmTransport.allowListener()

Invite the named receiver to reinstate certified delivery for its listeners, superseding the effect of any previous disallow calls.

TibrvCmTransport.destroy()

TibrvCmTransport.destroyEx()

Destroy a certified delivery transport.

TibrvCmTransport.disallowListener()

Cancel certified delivery to all listeners at a specific correspondent. Deny subsequent certified delivery registration requests from those listeners.

TibrvCmTransport.expireMessages()

Mark specified outbound CM messages as expired.

TibrvCmTransport.getDefaultTimeLimit()

Get the default message time limit for all outbound certified messages from a transport.

TibrvCmTransport.getLedgerName()

Extract the ledger name of a certified delivery transport.

TibrvCmTransport.getName()

Extract the correspondent name of a certified delivery transport or distributed queue member.

TibrvCmTransport.getRequestOld()

Extract the request old messages flag of a certified delivery transport.

TibrvCmTransport.getSyncLedger()

Extract the sync ledger flag of a certified delivery transport.

TibrvCmTransport.getTransport()

Extract the transport employed by a certified delivery transport or a distributed queue member.

TibrvCmTransport.removeListener()

Unregister a specific listener at a specific correspondent, and free associated storage in the sender’s ledger.

TibrvCmTransport.removeSendState()

Reclaim ledger space from obsolete subjects.

TibrvCmTransport.reviewLedger()

Query the ledger for stored items related to a subject name.

TibrvCmTransport.send()

Send a labeled message.

TibrvCmTransport.sendReply()

Send a labeled reply message.

TibrvCmTransport.sendRequest()

Send a labeled request message and wait for a reply.

TibrvCmTransport.setDefaultTimeLimit()

Set the default message time limit for all outbound certified messages from a transport.

TibrvCmTransport.setPublisherInactivityDiscardInterval()

Set a time limit after which a listening CM transport can discard state for inactive CM senders.

TibrvCmTransport.syncLedger()

Synchronize the ledger to its storage medium.

Inherited Methods

TibrvTransport.createInbox()

TibrvTransport.destroy()

TibrvTransport.isValid()

TibrvTransport.send()

TibrvTransport.sendReply()

TibrvTransport.sendRequest()

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

Field

Description

DEFAULT_TIME_LIMIT

The default time limit (in seconds) for certified messages sent on this transport.

The initial value is zero, a special value indicating that messages do not expire.

Programs can change this value using TibrvCmTransport.setDefaultTimeLimit().

Related Classes

TibrvTransport

TibrvRvdTransport

TibrvCmTransport

TibrvCmQueueTransport