public class JmsQueueConnector extends JmsConnector
embeddedConnectionFactory, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localPassword, 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,
java.lang.String queueName) |
protected javax.jms.Queue |
createForeignQueue(javax.jms.QueueSession session,
java.lang.String queueName) |
protected javax.jms.Destination |
createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection replyToProducerConnection,
javax.jms.Connection replyToConsumerConnection) |
InboundQueueBridge[] |
getInboundQueueBridges() |
java.lang.String |
getLocalConnectionFactoryName() |
javax.jms.QueueConnection |
getLocalQueueConnection() |
javax.jms.QueueConnectionFactory |
getLocalQueueConnectionFactory() |
OutboundQueueBridge[] |
getOutboundQueueBridges() |
javax.jms.QueueConnection |
getOutboundQueueConnection() |
javax.jms.QueueConnectionFactory |
getOutboundQueueConnectionFactory() |
java.lang.String |
getOutboundQueueConnectionFactoryName() |
boolean |
init() |
protected void |
initializeForeignQueueConnection() |
protected void |
initializeInboundJmsMessageConvertor() |
protected void |
initializeInboundQueueBridges() |
protected void |
initializeLocalQueueConnection() |
protected void |
initializeOutboundJmsMessageConvertor() |
protected void |
initializeOutboundQueueBridges() |
void |
restartProducerConnection() |
void |
setInboundQueueBridges(InboundQueueBridge[] inboundQueueBridges) |
void |
setLocalConnectionFactoryName(java.lang.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(java.lang.String foreignQueueConnectionFactoryName) |
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
public JmsQueueConnector()
public boolean init()
init
in class JmsConnector
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 java.lang.String getOutboundQueueConnectionFactoryName()
public void setOutboundQueueConnectionFactoryName(java.lang.String foreignQueueConnectionFactoryName)
outboundQueueConnectionFactoryName
- The
outboundQueueConnectionFactoryName to set.public java.lang.String getLocalConnectionFactoryName()
public void setLocalConnectionFactoryName(java.lang.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.public void restartProducerConnection() throws javax.naming.NamingException, javax.jms.JMSException
restartProducerConnection
in class JmsConnector
javax.naming.NamingException
javax.jms.JMSException
protected void initializeForeignQueueConnection() throws javax.naming.NamingException, javax.jms.JMSException
javax.naming.NamingException
javax.jms.JMSException
protected void initializeLocalQueueConnection() throws javax.naming.NamingException, javax.jms.JMSException
javax.naming.NamingException
javax.jms.JMSException
protected void initializeInboundJmsMessageConvertor()
protected void initializeOutboundJmsMessageConvertor()
protected void initializeInboundQueueBridges() throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundQueueBridges() 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, java.lang.String queueName) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Queue createForeignQueue(javax.jms.QueueSession session, java.lang.String queueName) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005-2012. All Rights Reserved.