org.apache.activemq.network.jms
Class JmsQueueConnector
java.lang.Object
org.apache.activemq.network.jms.JmsConnector
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 $
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 |
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 |
JmsQueueConnector
public JmsQueueConnector()
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.