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
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 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.