joram: org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule Class Reference

org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule ( Properties prop )

Constructs a BridgeUnifiedModule module.

Parameters:

prop

JMS properties required for establishing the link with the foreign JMS server.

Definition at line 149 of file JMSBridgeModule.java.

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.init ( AgentId agentId )

Initializes the module's parameters.

Parameters:

agentId

Identifier of the agent using the module.

Exceptions:

IllegalArgumentException

If the provided properties are invalid.

Definition at line 187 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.initialize(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.initialize().

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect ( ) throws JMSException

Launches the connection process to the foreign JMS server.

Exceptions:

	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.

Definition at line 199 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.initialize(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.initialize().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener ( ) throws IllegalStateException

Sets a message listener on the foreign JMS destination.

Exceptions:

javax.jms.IllegalStateException

If the module state does not allow to set a listener.

Definition at line 241 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumer, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerCnx, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.listener, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.notUsableMessage, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.usable.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.initialize(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.postSubscribe(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetMessageListener ( )

Unsets the set message listener on the foreign JMS destination.

Definition at line 259 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumer, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerCnx, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.listener, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetConsumer().

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.close(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.preUnsubscribe().

Here is the call graph for this function:

Message org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait ( ) throws IllegalStateException

Synchronous method requesting an immediate delivery from the foreign JMS destination.

Returns:: The JMS message formatted into a JORAM MOM message, or null if no message is available or if the request fails.

Exceptions:

javax.jms.IllegalStateException

If the module state does not allow to request a message.

Definition at line 282 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.receiveRequest().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receive ( ) throws IllegalStateException

Asynchronous method requesting a delivery from the foreign JMS destination.

Exceptions:

javax.jms.IllegalStateException

If the module state does not allow to request a message.

Definition at line 377 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerDaemon, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.notUsableMessage, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ConsumerDaemon.receive(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.usable.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.initialize(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.receiveRequest().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send ( org.objectweb.joram.shared.messages.Message message ) throws JMSException

Sends a message to the foreign JMS destination.

Exceptions:

	javax.jms.IllegalStateException	If the module's state does not permit message sendings.
	javax.jms.MessageFormatException	If the MOM message could not be converted into a foreign JMS message.

Definition at line 394 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.acknowledge(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.notUsableMessage, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.producer, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.qout, and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.usable.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.initialize(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.initialize(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.preProcess(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.preProcess(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.topicForwardNot().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.close ( )

Interrupts the daemons and closes the connection.

Definition at line 459 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerCnx, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerDaemon, fr.dyade.aaa.util.Daemon.interrupt(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.producerCnx, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.reconnectionDaemon, and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetMessageListener().

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.doDeleteNot(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.doDeleteNot().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.onException ( JMSException exc )

Implements the javax.jms.ExceptionListener interface for catching the failures of the connection to the remote JMS server.

Reacts by launching a reconnection process.

Definition at line 489 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.reconnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.reconnectionDaemon.

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.onMessage ( javax.jms.Message jmsMessage )

Implements the javax.jms.MessageListener interface for processing the asynchronous deliveries coming from the foreign JMS server.

Definition at line 500 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerSession, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, and fr.dyade.aaa.agent.AgentId.toString().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect ( ) throws JMSException [protected]

Opens a XA connection with the foreign JMS server and creates the XA JMS resources for interacting with the foreign JMS destination.

Exceptions:

JMSException

If the needed JMS resources could not be created.

Definition at line 585 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect ( ) throws JMSException [protected]

Opens a connection with the foreign JMS server and creates the JMS resources for interacting with the foreign JMS destination.

Exceptions:

JMSException

If the needed JMS resources could not be created.

Definition at line 630 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer ( ) throws JMSException [protected]

Sets the JMS consumer on the foreign destination.

Exceptions:

JMSException

If the JMS consumer could not be created.

Definition at line 663 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumer, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerSession, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.dest, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.selector, and fr.dyade.aaa.agent.AgentId.toString().

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ConsumerDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetConsumer ( ) [protected]

Unsets the JMS consumer.

Definition at line 692 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumer, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerSession, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.dest, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger, and fr.dyade.aaa.agent.AgentId.toString().

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetMessageListener().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.acknowledge ( Message message ) [protected]

Acknowledges a message successfuly delivered to the foreign JMS server.

Definition at line 709 of file JMSBridgeModule.java.

References org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId, and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send().

Logger org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.logger = Debug.getLogger(JMSBridgeModule.class.getName()) [static]

logger

Definition at line 69 of file JMSBridgeModule.java.

AgentId org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.agentId [protected]

Identifier of the agent using this module.

Definition at line 72 of file JMSBridgeModule.java.

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.jndiFactory = null [protected]

Name of the JNDI factory class to use.

Definition at line 75 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.jndiUrl = null [protected]

JNDI URL.

Definition at line 77 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.cnxFactName [protected]

ConnectionFactory JNDI name.

Definition at line 79 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.destName [protected]

Destination JNDI name.

Definition at line 81 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

ConnectionFactory org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.cnxFact = null [protected]

Connection factory object for connecting to the foreign JMS server.

Definition at line 83 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

XAConnectionFactory org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.xaCnxFact = null [protected]

XA Connection factory object for connecting to the foreign JMS server.

Definition at line 85 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

Destination org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.dest = null [protected]

Foreign JMS destination object.

Definition at line 87 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetConsumer().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.userName = null [protected]

User identification for connecting to the foreign JMS server.

Definition at line 89 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.password = null [protected]

User password for connecting to the foreign JMS server.

Definition at line 91 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.clientID = null [protected]

JMS clientID field.

Definition at line 93 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.selector [protected]

Selector for filtering messages.

Definition at line 95 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.JMSBridgeModule(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer().

boolean org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.usable = true [protected]

true if the module is fully usable.

Definition at line 98 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receive(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener().

String org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.notUsableMessage [protected]

Message explaining why the module is not usable.

Definition at line 100 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receive(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener().

transient Connection org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.producerCnx [protected]

Connection to the foreign JMS server.

Definition at line 103 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.close(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect().

transient Session org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.producerSession [protected]

Session for sending messages to the foreign JMS destination.

Definition at line 106 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect().

transient Session org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerSession [protected]

Session for getting messages from the foreign JMS destination.

Definition at line 108 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.onMessage(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetConsumer().

transient MessageProducer org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.producer [protected]

Producer object.

Definition at line 110 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doConnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.doXAConnect(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send().

transient MessageConsumer org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumer [protected]

Consumer object.

Definition at line 112 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receiveNoWait(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.reconnect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setConsumer(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetConsumer(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetMessageListener().

transient boolean org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.listener [protected]

true if a listener has been set on the JMS consumer.

Definition at line 115 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.setMessageListener(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.unsetMessageListener().

transient Vector org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.qout [protected]

Vector holding the pending messages to send after reconnection.

Definition at line 117 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.send().

transient ConsumerDaemon org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.consumerDaemon [protected]

Daemon used for requesting messages.

Definition at line 120 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.close(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.receive(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.ReconnectionDaemon.run(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

transient ReconnectionDaemon org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.reconnectionDaemon [protected]

Daemon used for the reconnection process.

Definition at line 122 of file JMSBridgeModule.java.

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.close(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.connect(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.onException(), and org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule.StartupDaemon.run().

org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeModule Class Reference

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Classes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation


Public Member Functions
	JMSBridgeModule (Properties prop)
void	init (AgentId agentId)
void	connect () throws JMSException
void	setMessageListener () throws IllegalStateException
void	unsetMessageListener ()
Message	receiveNoWait () throws IllegalStateException
void	receive () throws IllegalStateException
void	send (org.objectweb.joram.shared.messages.Message message) throws JMSException
void	close ()
void	onException (JMSException exc)
void	onMessage (javax.jms.Message jmsMessage)
Static Public Attributes
static Logger	logger = Debug.getLogger(JMSBridgeModule.class.getName())
Protected Member Functions
void	doXAConnect () throws JMSException
void	doConnect () throws JMSException
void	setConsumer () throws JMSException
void	unsetConsumer ()
void	acknowledge (Message message)
Protected Attributes
AgentId	agentId
String	jndiFactory = null
String	jndiUrl = null
String	cnxFactName
String	destName
ConnectionFactory	cnxFact = null
XAConnectionFactory	xaCnxFact = null
Destination	dest = null
String	userName = null
String	password = null
String	clientID = null
String	selector
boolean	usable = true
String	notUsableMessage
transient Connection	producerCnx
transient Connection	consumerCnx
transient Session	producerSession
transient Session	consumerSession
transient MessageProducer	producer
transient MessageConsumer	consumer
transient boolean	listener
transient Vector	qout
transient ConsumerDaemon	consumerDaemon
transient ReconnectionDaemon	reconnectionDaemon
Classes
class	ConsumerDaemon
class	ReconnectionDaemon
class	StartupDaemon
class	XARecoverDaemon