public abstract class RendezvousClientImp extends java.lang.Object implements RendezvousClient
Partial implementation of RendezvousClient.
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.commons.logging.Log |
log |
protected com.tibco.tibrv.TibrvQueue |
queue |
protected com.tibco.tibrv.TibrvRvdTransport |
transport |
| Constructor and Description |
|---|
RendezvousClientImp() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close this instance.
|
java.lang.String |
getDaemon()
Returns the
rvd daemon to connect to. |
java.lang.String |
getNetwork()
Returns the network interface to use.
|
java.lang.String |
getQueueName()
Returns the name of the
TibrvQueue to use for events. |
java.lang.String |
getService()
Returns the service to use.
|
void |
init()
Initialise this instance.
|
void |
send(com.tibco.tibrv.TibrvMsg tibrvMsg)
Sends the passed
TibrvMsg. |
void |
setDaemon(java.lang.String s)
Sets the
rvd daemon to connect to. |
void |
setNetwork(java.lang.String s)
Sets the network interface to use.
|
void |
setQueueName(java.lang.String s)
Sets the name of the
TibrvQueue to use for events. |
void |
setService(java.lang.String s)
Sets the service to use.
|
void |
start()
Start message delivery.
|
void |
stop()
Stop message delivery.
|
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcreateConfirmationListener, createMessageListenerprotected transient org.apache.commons.logging.Log log
protected transient com.tibco.tibrv.TibrvRvdTransport transport
protected transient com.tibco.tibrv.TibrvQueue queue
public void init()
throws com.tibco.tibrv.TibrvException
RendezvousClientInitialise this instance.
init in interface RendezvousClientcom.tibco.tibrv.TibrvException - if any occurRendezvousClient.init()public void start()
RendezvousClientStart message delivery.
start in interface RendezvousClientRendezvousClient.start()public void stop()
RendezvousClientStop message delivery.
stop in interface RendezvousClientRendezvousClient.stop()public void close()
RendezvousClientClose this instance.
close in interface RendezvousClientRendezvousClient.close()public void send(com.tibco.tibrv.TibrvMsg tibrvMsg)
throws com.tibco.tibrv.TibrvException
RendezvousClient
Sends the passed TibrvMsg.
send in interface RendezvousClienttibrvMsg - the message to sendcom.tibco.tibrv.TibrvException - if any occurRendezvousClient.send(com.tibco.tibrv.TibrvMsg)public java.lang.String toString()
toString in class java.lang.ObjectObject.toString()public java.lang.String getDaemon()
Returns the rvd daemon to connect to. If null a local
rvd daemon will be used.
rvd daemon to connect topublic void setDaemon(java.lang.String s)
Sets the rvd daemon to connect to. If null a local
rvd daemon will be used.
s - the dameon to connect topublic java.lang.String getNetwork()
Returns the network interface to use. If null the default network interface will be used.
public void setNetwork(java.lang.String s)
Sets the network interface to use. If null the default network interface will be used.
s - the network interface to usepublic java.lang.String getService()
Returns the service to use. If null the default service will be used.
public void setService(java.lang.String s)
Sets the service to use. If null the default service will be used.
s - the service to usepublic java.lang.String getQueueName()
Returns the name of the TibrvQueue to use for events. If null
the default queue will be used. NB this is a system queue for events and
not related to message destinations.
TibrvQueue to use for eventspublic void setQueueName(java.lang.String s)
Sets the name of the TibrvQueue to use for events. If null
the default queue will be used. NB this is a system queue for events and
not related to message destinations.
s - the name of the TibrvQueue to use for eventsCopyright Adaptris