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

Version:
$Revision: 1.1.1.1 $

Field Summary
 
Fields inherited from class org.apache.activemq.network.jms.JmsConnector
embeddedConnectionFactory, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localPassword, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, 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()
           
 boolean init()
           
protected  void initializeForeignQueueConnection()
           
protected  void initializeInboundJmsMessageConvertor()
           
protected  void initializeInboundQueueBridges()
           
protected  void initializeLocalQueueConnection()
           
protected  void initializeOutboundJmsMessageConvertor()
           
protected  void initializeOutboundQueueBridges()
           
 void restartProducerConnection()
           
 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, getInboundMessageConvertor, getJndiLocalTemplate, getJndiOutboundTemplate, getLocalClientId, getLocalPassword, getLocalUsername, getName, getOutboundClientId, getOutboundMessageConvertor, getOutboundPassword, getOutboundUsername, getReplyToDestinationCacheSize, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, 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

init

public boolean init()
Overrides:
init in class JmsConnector

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.

restartProducerConnection

public void restartProducerConnection()
                               throws NamingException,
                                      JMSException
Specified by:
restartProducerConnection in class JmsConnector
Throws:
NamingException
JMSException

initializeForeignQueueConnection

protected void initializeForeignQueueConnection()
                                         throws NamingException,
                                                JMSException
Throws:
NamingException
JMSException

initializeLocalQueueConnection

protected void initializeLocalQueueConnection()
                                       throws NamingException,
                                              JMSException
Throws:
NamingException
JMSException

initializeInboundJmsMessageConvertor

protected void initializeInboundJmsMessageConvertor()

initializeOutboundJmsMessageConvertor

protected void initializeOutboundJmsMessageConvertor()

initializeInboundQueueBridges

protected void initializeInboundQueueBridges()
                                      throws JMSException
Throws:
JMSException

initializeOutboundQueueBridges

protected void initializeOutboundQueueBridges()
                                       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-2011 Apache Software Foundation. All Rights Reserved.