|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.jms.JMSModule
org.objectweb.joram.mom.dest.jms.JMSAcquisition
public class JMSAcquisition
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.objectweb.joram.mom.dest.jms.JMSModule |
---|
JMSModule.ReconnectionDaemon, JMSModule.StartupDaemon, JMSModule.XARecoverDaemon |
Field Summary | |
---|---|
protected javax.jms.MessageConsumer |
consumer
Consumer object. |
protected java.lang.String |
selector
Selector for filtering messages. |
Fields inherited from class org.objectweb.joram.mom.dest.jms.JMSModule |
---|
clientID, cnx, cnxFact, cnxFactName, dest, destName, isXA, jndiFactory, jndiUrl, lock, notUsableMessage, password, reconnectionDaemon, session, usable, userName, xaRes |
Constructor Summary | |
---|---|
JMSAcquisition()
|
Method Summary | |
---|---|
protected void |
connectionDone()
Sets a message listener on the foreign JMS destination. |
void |
onMessage(javax.jms.Message jmsMessage)
Implements the MessageListener interface for processing the
asynchronous deliveries coming from the foreign JMS server. |
void |
start(java.util.Properties properties,
ReliableTransmitter transmitter)
Tells the daemon to start with the given properties. |
void |
stop()
Tells the daemon to stop. |
Methods inherited from class org.objectweb.joram.mom.dest.jms.JMSModule |
---|
close, doConnect, doXAConnect, init, onException |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected javax.jms.MessageConsumer consumer
protected java.lang.String selector
Constructor Detail |
---|
public JMSAcquisition()
Method Detail |
---|
public void start(java.util.Properties properties, ReliableTransmitter transmitter)
AcquisitionDaemon
start
in interface AcquisitionDaemon
properties
- The initial set of properties.transmitter
- a transmitter used to transmit retrieved messages to the MOM
reliably.public void stop()
AcquisitionDaemon
stop
in interface AcquisitionDaemon
protected void connectionDone()
connectionDone
in class JMSModule
javax.jms.IllegalStateException
- If the module state does not allow to set a listener.public void onMessage(javax.jms.Message jmsMessage)
MessageListener
interface for processing the
asynchronous deliveries coming from the foreign JMS server.
onMessage
in interface javax.jms.MessageListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |