org.objectweb.joram.mom.dest.jms
Class JMSDistribution

java.lang.Object
  extended by org.objectweb.joram.mom.dest.jms.JMSModule
      extended by org.objectweb.joram.mom.dest.jms.JMSDistribution
All Implemented Interfaces:
javax.jms.ExceptionListener, DistributionHandler

public class JMSDistribution
extends JMSModule
implements DistributionHandler


Nested Class Summary
 
Nested classes/interfaces inherited from class org.objectweb.joram.mom.dest.jms.JMSModule
JMSModule.ReconnectionDaemon, JMSModule.StartupDaemon, JMSModule.XARecoverDaemon
 
Field Summary
private static org.objectweb.util.monolog.api.Logger logger
           
protected  javax.jms.MessageProducer producer
          Producer object.
 
Fields inherited from class org.objectweb.joram.mom.dest.jms.JMSModule
clientID, cnx, cnxFact, cnxFactName, dest, destName, isXA, jndiFactory, jndiUrl, lock, notUsableMessage, password, reconnectionDaemon, session, usable, userName, xaRes
 
Constructor Summary
JMSDistribution()
           
 
Method Summary
 void distribute(Message message)
          Distributes the given message outside of the JORAM server.
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.
 
Methods inherited from class org.objectweb.joram.mom.dest.jms.JMSModule
close, connectionDone, init, onException
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.objectweb.joram.mom.dest.DistributionHandler
close, init
 

Field Detail

logger

private static final org.objectweb.util.monolog.api.Logger logger

producer

protected javax.jms.MessageProducer producer
Producer object.

Constructor Detail

JMSDistribution

public JMSDistribution()
Method Detail

distribute

public void distribute(Message message)
                throws java.lang.Exception
Description copied from interface: DistributionHandler
Distributes the given message outside of the JORAM server.

Specified by:
distribute in interface DistributionHandler
Parameters:
message - the message to distribute
Throws:
java.lang.Exception

doConnect

protected void doConnect()
                  throws javax.jms.JMSException
Opens a connection with the foreign JMS server and creates the JMS resources for interacting with the foreign JMS destination.

Overrides:
doConnect in class JMSModule
Throws:
javax.jms.JMSException - If the needed JMS resources could not be created.

doXAConnect

protected void doXAConnect()
                    throws javax.jms.JMSException
Opens a XA connection with the foreign JMS server and creates the XA JMS resources for interacting with the foreign JMS destination.

Overrides:
doXAConnect in class JMSModule
Throws:
javax.jms.JMSException - If the needed JMS resources could not be created.


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.