public class JmsQueueConnector extends JmsConnector
connectionSerivce, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started
Constructor and Description |
---|
JmsQueueConnector() |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Queue |
createActiveMQQueue(javax.jms.QueueSession session,
String queueName) |
protected javax.jms.Queue |
createForeignQueue(javax.jms.QueueSession session,
String queueName) |
protected javax.jms.Destination |
createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection replyToProducerConnection,
javax.jms.Connection replyToConsumerConnection) |
InboundQueueBridge[] |
getInboundQueueBridges() |
String |
getLocalConnectionFactoryName() |
javax.jms.QueueConnection |
getLocalQueueConnection() |
javax.jms.QueueConnectionFactory |
getLocalQueueConnectionFactory() |
OutboundQueueBridge[] |
getOutboundQueueBridges() |
javax.jms.QueueConnection |
getOutboundQueueConnection() |
javax.jms.QueueConnectionFactory |
getOutboundQueueConnectionFactory() |
String |
getOutboundQueueConnectionFactoryName() |
protected void |
initializeForeignConnection()
Performs the work of connection to the foreign side of the Connection.
|
protected void |
initializeInboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection) |
protected void |
initializeInboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection) |
protected void |
initializeLocalConnection()
Performs the work of connection to the local side of the Connection.
|
protected void |
initializeOutboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection) |
protected void |
initializeOutboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection) |
void |
setInboundQueueBridges(InboundQueueBridge[] inboundQueueBridges) |
void |
setLocalConnectionFactoryName(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(String foreignQueueConnectionFactoryName) |
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
public InboundQueueBridge[] getInboundQueueBridges()
public void setInboundQueueBridges(InboundQueueBridge[] inboundQueueBridges)
inboundQueueBridges
- The inboundQueueBridges to set.public OutboundQueueBridge[] getOutboundQueueBridges()
public void setOutboundQueueBridges(OutboundQueueBridge[] outboundQueueBridges)
outboundQueueBridges
- The outboundQueueBridges to set.public javax.jms.QueueConnectionFactory getLocalQueueConnectionFactory()
public void setLocalQueueConnectionFactory(javax.jms.QueueConnectionFactory localConnectionFactory)
localQueueConnectionFactory
- The localQueueConnectionFactory to
set.public javax.jms.QueueConnectionFactory getOutboundQueueConnectionFactory()
public String getOutboundQueueConnectionFactoryName()
public void setOutboundQueueConnectionFactoryName(String foreignQueueConnectionFactoryName)
outboundQueueConnectionFactoryName
- The
outboundQueueConnectionFactoryName to set.public String getLocalConnectionFactoryName()
public void setLocalConnectionFactoryName(String localConnectionFactoryName)
localConnectionFactoryName
- The localConnectionFactoryName to set.public javax.jms.QueueConnection getLocalQueueConnection()
public void setLocalQueueConnection(javax.jms.QueueConnection localQueueConnection)
localQueueConnection
- The localQueueConnection to set.public javax.jms.QueueConnection getOutboundQueueConnection()
public void setOutboundQueueConnection(javax.jms.QueueConnection foreignQueueConnection)
outboundQueueConnection
- The outboundQueueConnection to set.public void setOutboundQueueConnectionFactory(javax.jms.QueueConnectionFactory foreignQueueConnectionFactory)
outboundQueueConnectionFactory
- The outboundQueueConnectionFactory
to set.protected void initializeForeignConnection() throws NamingException, javax.jms.JMSException
JmsConnector
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.
initializeForeignConnection
in class JmsConnector
NamingException
javax.jms.JMSException
protected void initializeLocalConnection() throws NamingException, javax.jms.JMSException
JmsConnector
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.
initializeLocalConnection
in class JmsConnector
NamingException
javax.jms.JMSException
protected void initializeInboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeInboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundDestinationBridgesOutboundSide(javax.jms.QueueConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundDestinationBridgesLocalSide(javax.jms.QueueConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Destination createReplyToBridge(javax.jms.Destination destination, javax.jms.Connection replyToProducerConnection, javax.jms.Connection replyToConsumerConnection)
createReplyToBridge
in class JmsConnector
protected javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession session, String queueName) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Queue createForeignQueue(javax.jms.QueueSession session, String queueName) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.