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 |
connectionSerivce, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started |
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, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setReconnectionPolicy, setReplyToDestinationCacheSize, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsQueueConnector
public JmsQueueConnector()
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.
initializeForeignConnection
protected void initializeForeignConnection()
throws javax.naming.NamingException,
javax.jms.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:
javax.naming.NamingException
javax.jms.JMSException
initializeLocalConnection
protected void initializeLocalConnection()
throws javax.naming.NamingException,
javax.jms.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:
javax.naming.NamingException
javax.jms.JMSException
initializeInboundDestinationBridgesOutboundSide
protected void initializeInboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeInboundDestinationBridgesLocalSide
protected void initializeInboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeOutboundDestinationBridgesOutboundSide
protected void initializeOutboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeOutboundDestinationBridgesLocalSide
protected void initializeOutboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection)
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-2012. All Rights Reserved.