org.objectweb.joram.mom.util
Class BridgePubSubModule

java.lang.Object
  extended byorg.objectweb.joram.mom.util.BridgeUnifiedModule
      extended byorg.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.


Copyright ? 2004 Scalagent - All rights reserved