Package com.adaptris.tibrv
Interface RendezvousClient
- All Known Implementing Classes:
CertifiedRendezvousClient
,RendezvousClientImp
,StandardRendezvousClient
public interface RendezvousClient
Interface to Tibco Rendezvous. Implementations of this class may not be thread safe.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Close this instance.void
createConfirmationListener
(com.tibco.tibrv.TibrvMsgCallback callback) Creates aTibrvListener
for confirmation messages, which may be useful for debugging / troubleshooting.void
createMessageListener
(com.tibco.tibrv.TibrvMsgCallback callback, String sendSubject) Creates aTibrvListener
using the passedcallback
andsendSubject
.void
init()
Initialise this instance.void
send
(com.tibco.tibrv.TibrvMsg tibrvMsg) Sends the passedTibrvMsg
.void
start()
Start message delivery.void
stop()
Stop message delivery.
-
Method Details
-
createMessageListener
void createMessageListener(com.tibco.tibrv.TibrvMsgCallback callback, String sendSubject) throws com.tibco.tibrv.TibrvException Creates a
TibrvListener
using the passedcallback
andsendSubject
. Not part ofinit
as only required by client code which consumes messages.- Parameters:
callback
- theTibrvMsgCallback
(some sort of consumer)sendSubject
- the send subject, conforming to TibcoRendezvous rules- Throws:
com.tibco.tibrv.TibrvException
- if any occur
-
createConfirmationListener
void createConfirmationListener(com.tibco.tibrv.TibrvMsgCallback callback) throws com.tibco.tibrv.TibrvException Creates a
TibrvListener
for confirmation messages, which may be useful for debugging / troubleshooting.- Parameters:
callback
- theTibrvMsgCallback
to use- Throws:
com.tibco.tibrv.TibrvException
- if any occur
-
send
void send(com.tibco.tibrv.TibrvMsg tibrvMsg) throws com.tibco.tibrv.TibrvException Sends the passed
TibrvMsg
.- Parameters:
tibrvMsg
- the message to send- Throws:
com.tibco.tibrv.TibrvException
- if any occur
-
init
void init() throws com.tibco.tibrv.TibrvExceptionInitialise this instance.
- Throws:
com.tibco.tibrv.TibrvException
- if any occur
-
start
void start() throws com.tibco.tibrv.TibrvExceptionStart message delivery.
- Throws:
com.tibco.tibrv.TibrvException
- if any occur
-
stop
void stop()Stop message delivery.
-
close
void close()Close this instance.
-