org.apache.activemq.network.jms
Class JmsQueueConnector

java.lang.Object
  extended by org.apache.activemq.network.jms.JmsConnector
      extended by org.apache.activemq.network.jms.JmsQueueConnector
All Implemented Interfaces:
Service

public class JmsQueueConnector
extends JmsConnector

A Bridge to other JMS Queue providers


Field Summary
 
Fields inherited from class org.apache.activemq.network.jms.JmsConnector
connectionSerivce, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, preferJndiDestinationLookup, replyToBridges, replyToDestinationCacheSize, started
 
Constructor Summary
JmsQueueConnector()
           
 
Method Summary
protected  Queue createActiveMQQueue(QueueSession session, String queueName)
           
protected  Queue createForeignQueue(QueueSession session, String queueName)
           
protected  Destination createReplyToBridge(Destination destination, Connection replyToProducerConnection, Connection replyToConsumerConnection)
           
 InboundQueueBridge[] getInboundQueueBridges()
           
 String getLocalConnectionFactoryName()
           
 QueueConnection getLocalQueueConnection()
           
 QueueConnectionFactory getLocalQueueConnectionFactory()
           
 OutboundQueueBridge[] getOutboundQueueBridges()
           
 QueueConnection getOutboundQueueConnection()
           
 QueueConnectionFactory getOutboundQueueConnectionFactory()
           
 String getOutboundQueueConnectionFactoryName()
           
protected  void initializeForeignConnection()
          Performs the work of connection to the foreign side of the Connection.
protected  void initializeInboundDestinationBridgesLocalSide(QueueConnection connection)
           
protected  void initializeInboundDestinationBridgesOutboundSide(QueueConnection connection)
           
protected  void initializeLocalConnection()
          Performs the work of connection to the local side of the Connection.
protected  void initializeOutboundDestinationBridgesLocalSide(QueueConnection connection)
           
protected  void initializeOutboundDestinationBridgesOutboundSide(QueueConnection connection)
           
 void setInboundQueueBridges(InboundQueueBridge[] inboundQueueBridges)
           
 void setLocalConnectionFactoryName(String localConnectionFactoryName)
           
 void setLocalQueueConnection(QueueConnection localQueueConnection)
           
 void setLocalQueueConnectionFactory(QueueConnectionFactory localConnectionFactory)
           
 void setOutboundQueueBridges(OutboundQueueBridge[] outboundQueueBridges)
           
 void setOutboundQueueConnection(QueueConnection foreignQueueConnection)
           
 void setOutboundQueueConnectionFactory(QueueConnectionFactory foreignQueueConnectionFactory)
           
 void setOutboundQueueConnectionFactoryName(String foreignQueueConnectionFactoryName)
           
 
Methods inherited from class org.apache.activemq.network.jms.JmsConnector
addInboundBridge, addOutboundBridge, clearBridges, doConnectorInit, getForeignConnection, getInboundMessageConvertor, getJndiLocalTemplate, getJndiOutboundTemplate, getLocalClientId, getLocalConnection, getLocalPassword, getLocalUsername, getName, getOutboundClientId, getOutboundMessageConvertor, getOutboundPassword, getOutboundUsername, getReconnectionPolicy, getReplyToDestinationCacheSize, init, isConnected, isFailed, isPreferJndiDestinationLookup, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setPreferJndiDestinationLookup, setReconnectionPolicy, setReplyToDestinationCacheSize, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JmsQueueConnector

public JmsQueueConnector()
Method Detail

getInboundQueueBridges

public InboundQueueBridge[] getInboundQueueBridges()
Returns:
Returns the inboundQueueBridges.

setInboundQueueBridges

public void setInboundQueueBridges(InboundQueueBridge[] inboundQueueBridges)
Parameters:
inboundQueueBridges - The inboundQueueBridges to set.

getOutboundQueueBridges

public OutboundQueueBridge[] getOutboundQueueBridges()
Returns:
Returns the outboundQueueBridges.

setOutboundQueueBridges

public void setOutboundQueueBridges(OutboundQueueBridge[] outboundQueueBridges)
Parameters:
outboundQueueBridges - The outboundQueueBridges to set.

getLocalQueueConnectionFactory

public QueueConnectionFactory getLocalQueueConnectionFactory()
Returns:
Returns the localQueueConnectionFactory.

setLocalQueueConnectionFactory

public void setLocalQueueConnectionFactory(QueueConnectionFactory localConnectionFactory)
Parameters:
localQueueConnectionFactory - The localQueueConnectionFactory to set.

getOutboundQueueConnectionFactory

public QueueConnectionFactory getOutboundQueueConnectionFactory()
Returns:
Returns the outboundQueueConnectionFactory.

getOutboundQueueConnectionFactoryName

public String getOutboundQueueConnectionFactoryName()
Returns:
Returns the outboundQueueConnectionFactoryName.

setOutboundQueueConnectionFactoryName

public void setOutboundQueueConnectionFactoryName(String foreignQueueConnectionFactoryName)
Parameters:
outboundQueueConnectionFactoryName - The outboundQueueConnectionFactoryName to set.

getLocalConnectionFactoryName

public String getLocalConnectionFactoryName()
Returns:
Returns the localConnectionFactoryName.

setLocalConnectionFactoryName

public void setLocalConnectionFactoryName(String localConnectionFactoryName)
Parameters:
localConnectionFactoryName - The localConnectionFactoryName to set.

getLocalQueueConnection

public QueueConnection getLocalQueueConnection()
Returns:
Returns the localQueueConnection.

setLocalQueueConnection

public void setLocalQueueConnection(QueueConnection localQueueConnection)
Parameters:
localQueueConnection - The localQueueConnection to set.

getOutboundQueueConnection

public QueueConnection getOutboundQueueConnection()
Returns:
Returns the outboundQueueConnection.

setOutboundQueueConnection

public void setOutboundQueueConnection(QueueConnection foreignQueueConnection)
Parameters:
outboundQueueConnection - The outboundQueueConnection to set.

setOutboundQueueConnectionFactory

public void setOutboundQueueConnectionFactory(QueueConnectionFactory foreignQueueConnectionFactory)
Parameters:
outboundQueueConnectionFactory - The outboundQueueConnectionFactory to set.

initializeForeignConnection

protected void initializeForeignConnection()
                                    throws NamingException,
                                           JMSException
Description copied from class: JmsConnector
Performs the work of connection to the foreign side of the Connection.

This creates the initial connection to the foreign end of the JmsConnector and then sets up all the destination bridges with the information needed to bridge on the foreign side of the connection.

Specified by:
initializeForeignConnection in class JmsConnector
Throws:
NamingException
JMSException

initializeLocalConnection

protected void initializeLocalConnection()
                                  throws NamingException,
                                         JMSException
Description copied from class: JmsConnector
Performs the work of connection to the local side of the Connection.

This creates the initial connection to the local end of the JmsConnector and then sets up all the destination bridges with the information needed to bridge on the local side of the connection.

Specified by:
initializeLocalConnection in class JmsConnector
Throws:
NamingException
JMSException

initializeInboundDestinationBridgesOutboundSide

protected void initializeInboundDestinationBridgesOutboundSide(QueueConnection connection)
                                                        throws JMSException
Throws:
JMSException

initializeInboundDestinationBridgesLocalSide

protected void initializeInboundDestinationBridgesLocalSide(QueueConnection connection)
                                                     throws JMSException
Throws:
JMSException

initializeOutboundDestinationBridgesOutboundSide

protected void initializeOutboundDestinationBridgesOutboundSide(QueueConnection connection)
                                                         throws JMSException
Throws:
JMSException

initializeOutboundDestinationBridgesLocalSide

protected void initializeOutboundDestinationBridgesLocalSide(QueueConnection connection)
                                                      throws JMSException
Throws:
JMSException

createReplyToBridge

protected Destination createReplyToBridge(Destination destination,
                                          Connection replyToProducerConnection,
                                          Connection replyToConsumerConnection)
Specified by:
createReplyToBridge in class JmsConnector

createActiveMQQueue

protected Queue createActiveMQQueue(QueueSession session,
                                    String queueName)
                             throws JMSException
Throws:
JMSException

createForeignQueue

protected Queue createForeignQueue(QueueSession session,
                                   String queueName)
                            throws JMSException
Throws:
JMSException


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.