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
embeddedConnectionFactory, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localPassword, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started
 
Constructor Summary
JmsQueueConnector()
           
 
Method Summary
protected  javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession session, java.lang.String queueName)
           
protected  javax.jms.Queue createForeignQueue(javax.jms.QueueSession session, java.lang.String queueName)
           
protected  javax.jms.Destination createReplyToBridge(javax.jms.Destination destination, javax.jms.Connection replyToProducerConnection, javax.jms.Connection replyToConsumerConnection)
           
 InboundQueueBridge[] getInboundQueueBridges()
           
 java.lang.String getLocalConnectionFactoryName()
           
 javax.jms.QueueConnection getLocalQueueConnection()
           
 javax.jms.QueueConnectionFactory getLocalQueueConnectionFactory()
           
 OutboundQueueBridge[] getOutboundQueueBridges()
           
 javax.jms.QueueConnection getOutboundQueueConnection()
           
 javax.jms.QueueConnectionFactory getOutboundQueueConnectionFactory()
           
 java.lang.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(java.lang.String localConnectionFactoryName)
           
 void setLocalQueueConnection(javax.jms.QueueConnection localQueueConnection)
           
 void setLocalQueueConnectionFactory(javax.jms.QueueConnectionFactory localConnectionFactory)
           
 void setOutboundQueueBridges(OutboundQueueBridge[] outboundQueueBridges)
           
 void setOutboundQueueConnection(javax.jms.QueueConnection foreignQueueConnection)
           
 void setOutboundQueueConnectionFactory(javax.jms.QueueConnectionFactory foreignQueueConnectionFactory)
           
 void setOutboundQueueConnectionFactoryName(java.lang.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 javax.jms.QueueConnectionFactory getLocalQueueConnectionFactory()
Returns:
Returns the localQueueConnectionFactory.

setLocalQueueConnectionFactory

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

getOutboundQueueConnectionFactory

public javax.jms.QueueConnectionFactory getOutboundQueueConnectionFactory()
Returns:
Returns the outboundQueueConnectionFactory.

getOutboundQueueConnectionFactoryName

public java.lang.String getOutboundQueueConnectionFactoryName()
Returns:
Returns the outboundQueueConnectionFactoryName.

setOutboundQueueConnectionFactoryName

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

getLocalConnectionFactoryName

public java.lang.String getLocalConnectionFactoryName()
Returns:
Returns the localConnectionFactoryName.

setLocalConnectionFactoryName

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

getLocalQueueConnection

public javax.jms.QueueConnection getLocalQueueConnection()
Returns:
Returns the localQueueConnection.

setLocalQueueConnection

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

getOutboundQueueConnection

public javax.jms.QueueConnection getOutboundQueueConnection()
Returns:
Returns the outboundQueueConnection.

setOutboundQueueConnection

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

setOutboundQueueConnectionFactory

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

restartProducerConnection

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

initializeForeignQueueConnection

protected void initializeForeignQueueConnection()
                                         throws javax.naming.NamingException,
                                                javax.jms.JMSException
Throws:
javax.naming.NamingException
javax.jms.JMSException

initializeLocalQueueConnection

protected void initializeLocalQueueConnection()
                                       throws javax.naming.NamingException,
                                              javax.jms.JMSException
Throws:
javax.naming.NamingException
javax.jms.JMSException

initializeInboundJmsMessageConvertor

protected void initializeInboundJmsMessageConvertor()

initializeOutboundJmsMessageConvertor

protected void initializeOutboundJmsMessageConvertor()

initializeInboundQueueBridges

protected void initializeInboundQueueBridges()
                                      throws javax.jms.JMSException
Throws:
javax.jms.JMSException

initializeOutboundQueueBridges

protected void initializeOutboundQueueBridges()
                                       throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createReplyToBridge

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

createActiveMQQueue

protected javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession session,
                                              java.lang.String queueName)
                                       throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createForeignQueue

protected javax.jms.Queue createForeignQueue(javax.jms.QueueSession session,
                                             java.lang.String queueName)
                                      throws javax.jms.JMSException
Throws:
javax.jms.JMSException


Copyright © 2005-2011. All Rights Reserved.