Package org.apache.activemq.network.jms
Class SimpleJmsQueueConnector
- java.lang.Object
-
- org.apache.activemq.network.jms.JmsConnector
-
- org.apache.activemq.network.jms.SimpleJmsQueueConnector
-
- All Implemented Interfaces:
Service
- Direct Known Subclasses:
JmsQueueConnector
public class SimpleJmsQueueConnector extends JmsConnector
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.network.jms.JmsConnector
connectionService, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, preferJndiDestinationLookup, replyToBridges, replyToDestinationCacheSize, started
-
-
Constructor Summary
Constructors Constructor Description SimpleJmsQueueConnector()
-
Method Summary
-
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, isPreferJndiDestinationLookup, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setPreferJndiDestinationLookup, setReconnectionPolicy, setReplyToDestinationCacheSize, start, stop
-
-
-
-
Method Detail
-
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:
localConnectionFactory
- 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:
foreignQueueConnectionFactoryName
- The foreignQueueConnectionFactoryName 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:
foreignQueueConnection
- The foreignQueueConnection to set.
-
setOutboundQueueConnectionFactory
public void setOutboundQueueConnectionFactory(QueueConnectionFactory foreignQueueConnectionFactory)
- Parameters:
foreignQueueConnectionFactory
- The foreignQueueConnectionFactory to set.
-
initializeForeignConnection
protected void initializeForeignConnection() throws NamingException, 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 classJmsConnector
- Throws:
NamingException
JMSException
-
initializeLocalConnection
protected void initializeLocalConnection() throws NamingException, 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 classJmsConnector
- Throws:
NamingException
JMSException
-
initializeInboundDestinationBridgesOutboundSide
protected void initializeInboundDestinationBridgesOutboundSide(QueueConnection connection) throws JMSException
- Throws:
JMSException
-
initializeInboundDestinationBridgesLocalSide
protected void initializeInboundDestinationBridgesLocalSide(QueueConnection connection) throws JMSException
- Throws:
JMSException
-
initializeOutboundDestinationBridgesOutboundSide
protected void initializeOutboundDestinationBridgesOutboundSide(QueueConnection connection) throws JMSException
- Throws:
JMSException
-
initializeOutboundDestinationBridgesLocalSide
protected void initializeOutboundDestinationBridgesLocalSide(QueueConnection connection) throws JMSException
- Throws:
JMSException
-
createReplyToBridge
protected Destination createReplyToBridge(Destination destination, Connection replyToProducerConnection, Connection replyToConsumerConnection)
- Specified by:
createReplyToBridge
in classJmsConnector
-
createActiveMQQueue
protected Queue createActiveMQQueue(QueueSession session, String queueName) throws JMSException
- Throws:
JMSException
-
createForeignQueue
protected Queue createForeignQueue(QueueSession session, String queueName) throws JMSException
- Throws:
JMSException
-
-