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, wait
createConfirmationListener, createMessageListener
protected 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
RendezvousClient
Initialise this instance.
init
in interface RendezvousClient
com.tibco.tibrv.TibrvException
- if any occurRendezvousClient.init()
public void start()
RendezvousClient
Start message delivery.
start
in interface RendezvousClient
RendezvousClient.start()
public void stop()
RendezvousClient
Stop message delivery.
stop
in interface RendezvousClient
RendezvousClient.stop()
public void close()
RendezvousClient
Close this instance.
close
in interface RendezvousClient
RendezvousClient.close()
public void send(com.tibco.tibrv.TibrvMsg tibrvMsg) throws com.tibco.tibrv.TibrvException
RendezvousClient
Sends the passed TibrvMsg
.
send
in interface RendezvousClient
tibrvMsg
- 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.Object
Object.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