Package com.adaptris.tibrv

Class StandardRendezvousClient

java.lang.Object

com.adaptris.tibrv.RendezvousClientImp

com.adaptris.tibrv.StandardRendezvousClient

All Implemented Interfaces:

RendezvousClient

public class StandardRendezvousClient
extends RendezvousClientImp

Implementation of RendezvousClient which provides reliable message delivery.

In the adapter configuration file this class is aliased as standard-rendezvous-client which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.tibrv.RendezvousClientImp

log, queue, transport

Constructor Summary

Constructors

Constructor	Description
StandardRendezvousClient()

Method Summary

Modifier and Type	Method	Description
void	close()	Close this instance.
void	createConfirmationListener(com.tibco.tibrv.TibrvMsgCallback callback)	Creates a TibrvListener for confirmation messages, which may be useful for debugging / troubleshooting.
void	createMessageListener(com.tibco.tibrv.TibrvMsgCallback callback, String sendSubject)	Note - this does look a bit odd - creating the listener but not either returning it or retaining a reference to it.

Methods inherited from class com.adaptris.tibrv.RendezvousClientImp

getDaemon, getNetwork, getQueueName, getService, init, send, setDaemon, setNetwork, setQueueName, setService, start, stop, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

StandardRendezvousClient

public StandardRendezvousClient()

Method Details

createMessageListener

public void createMessageListener(com.tibco.tibrv.TibrvMsgCallback callback,
 String sendSubject)
                           throws com.tibco.tibrv.TibrvException

Note - this does look a bit odd - creating the listener but not either returning it or retaining a reference to it. The TibrvTransport retains a reference to it, as it (the listener) is passed in to onTibrvMsg. Also note closure is not exposed for now.

Parameters:

callback - the TibrvMsgCallback (some sort of consumer)

sendSubject - the send subject, conforming to TibcoRendezvous rules

Throws:

com.tibco.tibrv.TibrvException - if any occur

See Also:

• (com.tibco.tibrv.TibrvMsgCallback, java.lang.String)

createConfirmationListener

public void createConfirmationListener(com.tibco.tibrv.TibrvMsgCallback callback)
                                throws com.tibco.tibrv.TibrvException

Description copied from interface: RendezvousClient

Creates a TibrvListener for confirmation messages, which may be useful for debugging / troubleshooting.

Parameters:

callback - the TibrvMsgCallback to use

Throws:

com.tibco.tibrv.TibrvException - if any occur

See Also:

• #createConfirmationListener(com.tibco.tibrv.TibrvMsgCallback)

close

public void close()

Description copied from interface: RendezvousClient

Close this instance.

Specified by:

close in interface RendezvousClient

Overrides:

close in class RendezvousClientImp

See Also:

• RendezvousClientImp.close()