|
|||||||||
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
public class JMSModule
Nested Class Summary | |
---|---|
protected class |
JMSModule.ReconnectionDaemon
The ReconnectionDaemon thread is responsible for reconnecting
the bridge module with the foreign JMS server in case of disconnection. |
protected class |
JMSModule.StartupDaemon
The StartupDaemon thread is responsible for retrieving the
needed JMS administered objects from the JNDI server. |
protected class |
JMSModule.XARecoverDaemon
|
Field Summary | |
---|---|
protected java.lang.String |
clientID
JMS clientID field. |
protected javax.jms.Connection |
cnx
Connection to the foreign JMS server. |
protected javax.jms.ConnectionFactory |
cnxFact
Connection factory object for connecting to the foreign JMS server. |
protected java.lang.String |
cnxFactName
ConnectionFactory JNDI name. |
protected javax.jms.Destination |
dest
Foreign JMS destination object. |
protected java.lang.String |
destName
Destination JNDI name. |
protected boolean |
isXA
Indicates to use an XAConnection. |
protected java.lang.String |
jndiFactory
Name of the JNDI factory class to use. |
protected java.lang.String |
jndiUrl
JNDI URL. |
protected java.lang.Object |
lock
serializable object for synchronization |
private static org.objectweb.util.monolog.api.Logger |
logger
|
protected java.lang.String |
notUsableMessage
Message explaining why the module is not usable. |
protected java.lang.String |
password
User password for connecting to the foreign JMS server. |
protected JMSModule.ReconnectionDaemon |
reconnectionDaemon
Daemon used for the reconnection process. |
protected javax.jms.Session |
session
Session with the foreign JMS destination. |
protected boolean |
usable
true if the module is fully usable. |
protected java.lang.String |
userName
User identification for connecting to the foreign JMS server. |
protected javax.transaction.xa.XAResource |
xaRes
XAResource |
Constructor Summary | |
---|---|
JMSModule()
|
Method Summary | |
---|---|
void |
close()
|
private void |
connect()
Launches the connection process to the foreign JMS server. |
protected void |
connectionDone()
|
protected void |
doConnect()
Opens a connection with the foreign JMS server and creates the JMS resources for interacting with the foreign JMS destination. |
protected void |
doXAConnect()
Opens a XA connection with the foreign JMS server and creates the XA JMS resources for interacting with the foreign JMS destination. |
void |
init(java.util.Properties properties)
|
void |
onException(javax.jms.JMSException exc)
Implements the javax.jms.ExceptionListener interface for
catching the failures of the connection to the remote JMS server. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final org.objectweb.util.monolog.api.Logger logger
protected boolean usable
true
if the module is fully usable.
protected java.lang.String notUsableMessage
protected JMSModule.ReconnectionDaemon reconnectionDaemon
protected java.lang.Object lock
protected boolean isXA
protected javax.jms.Connection cnx
protected javax.jms.Session session
protected javax.transaction.xa.XAResource xaRes
protected java.lang.String userName
protected java.lang.String password
protected java.lang.String jndiFactory
protected java.lang.String jndiUrl
protected java.lang.String cnxFactName
protected java.lang.String destName
protected javax.jms.Destination dest
protected java.lang.String clientID
protected javax.jms.ConnectionFactory cnxFact
Constructor Detail |
---|
public JMSModule()
Method Detail |
---|
public void init(java.util.Properties properties)
public void close()
private void connect() throws javax.jms.JMSException
javax.jms.IllegalStateException
- If the module can't access the foreign JMS server.
javax.jms.JMSException
- If the needed JMS resources can't be created.protected void doConnect() throws javax.jms.JMSException
javax.jms.JMSException
- If the needed JMS resources could not be created.protected void doXAConnect() throws javax.jms.JMSException
javax.jms.JMSException
- If the needed JMS resources could not be created.public void onException(javax.jms.JMSException exc)
javax.jms.ExceptionListener
interface for
catching the failures of the connection to the remote JMS server.
Reacts by launching a reconnection process.
onException
in interface javax.jms.ExceptionListener
protected void connectionDone()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |