org.objectweb.joram.mom.util
Class BridgePubSubModule

java.lang.Object
  org.objectweb.joram.mom.util.BridgeUnifiedModule
      org.objectweb.joram.mom.util.BridgePubSubModule

All Implemented Interfaces:

javax.jms.ExceptionListener, javax.jms.MessageListener, java.io.Serializable

public class BridgePubSubModule

extends BridgeUnifiedModule

The BridgePubSubModule class is a bridge module based on the JMS Publish/Subscribe semantics and classes.

See Also:

Serialized Form

Nested Class Summary

Nested classes inherited from class org.objectweb.joram.mom.util.BridgeUnifiedModule

BridgeUnifiedModule.ConsumerDaemon, BridgeUnifiedModule.ReconnectionDaemon, BridgeUnifiedModule.StartupDaemon

Field Summary

Fields inherited from class org.objectweb.joram.mom.util.BridgeUnifiedModule

agentId, clientID, cnx, cnxFact, cnxFactName, consumer, consumerDaemon, consumerSession, dest, destName, jndiFactory, jndiUrl, listener, notUsableMessage, password, producer, producerSession, qout, reconnectionDaemon, selector, usable, userName

Constructor Summary

BridgePubSubModule()
Constructs a BridgePubSubModule module.

Method Summary

protected void	doConnect() Opens a connection with the foreign JMS server and creates the JMS Pub/Sub resources for interacting with the foreign JMS topic.
void	send(Message message) Sends a message to the foreign JMS topic.

Methods inherited from class org.objectweb.joram.mom.util.BridgeUnifiedModule

acknowledge, close, connect, init, onException, onMessage, receive, receiveNoWait, setConsumer, setMessageListener, unsetConsumer, unsetMessageListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BridgePubSubModule

public BridgePubSubModule()

Constructs a BridgePubSubModule module.

Method Detail

send

public void send(Message message)
          throws javax.jms.JMSException

Sends a message to the foreign JMS topic.

Overrides:

send in class BridgeUnifiedModule

Throws:

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.

javax.jms.JMSException

doConnect

protected void doConnect()
                  throws javax.jms.JMSException

Opens a connection with the foreign JMS server and creates the JMS Pub/Sub resources for interacting with the foreign JMS topic.

Overrides:

doConnect in class BridgeUnifiedModule

Throws:

javax.jms.JMSException - If the needed JMS resources could not be created.