org.objectweb.joram.mom.util

Class BridgePubSubModule

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/interfaces 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, doConnect, init, onException, onMessage, receive, receiveNoWait, send, setConsumer, setMessageListener, unsetConsumer, unsetMessageListener

Constructor Details

BridgePubSubModule

public BridgePubSubModule()
Constructs a BridgePubSubModule module.

Method Details

doConnect

protected void doConnect()
            throws 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 interface BridgeUnifiedModule


send

public void send(Message message)
            throws JMSException
Sends a message to the foreign JMS topic.
Overrides:
send in interface BridgeUnifiedModule


Copyright B) 2004 Scalagent - All rights reserved