public class JmsTopicConnector extends JmsConnector
embeddedConnectionFactory, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localPassword, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started
Constructor and Description |
---|
JmsTopicConnector() |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Topic |
createActiveMQTopic(javax.jms.TopicSession session,
java.lang.String topicName) |
protected javax.jms.Topic |
createForeignTopic(javax.jms.TopicSession session,
java.lang.String topicName) |
protected javax.jms.Destination |
createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection replyToProducerConnection,
javax.jms.Connection replyToConsumerConnection) |
InboundTopicBridge[] |
getInboundTopicBridges() |
java.lang.String |
getLocalConnectionFactoryName() |
javax.jms.TopicConnection |
getLocalTopicConnection() |
javax.jms.TopicConnectionFactory |
getLocalTopicConnectionFactory() |
OutboundTopicBridge[] |
getOutboundTopicBridges() |
javax.jms.TopicConnection |
getOutboundTopicConnection() |
javax.jms.TopicConnectionFactory |
getOutboundTopicConnectionFactory() |
java.lang.String |
getOutboundTopicConnectionFactoryName() |
boolean |
init() |
protected void |
initializeForeignTopicConnection() |
protected void |
initializeInboundJmsMessageConvertor() |
protected void |
initializeInboundTopicBridges() |
protected void |
initializeLocalTopicConnection() |
protected void |
initializeOutboundJmsMessageConvertor() |
protected void |
initializeOutboundTopicBridges() |
void |
restartProducerConnection() |
void |
setInboundTopicBridges(InboundTopicBridge[] inboundTopicBridges) |
void |
setLocalConnectionFactoryName(java.lang.String localConnectionFactoryName) |
void |
setLocalTopicConnection(javax.jms.TopicConnection localTopicConnection) |
void |
setLocalTopicConnectionFactory(javax.jms.TopicConnectionFactory localConnectionFactory) |
void |
setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges) |
void |
setOutboundTopicConnection(javax.jms.TopicConnection foreignTopicConnection) |
void |
setOutboundTopicConnectionFactory(javax.jms.TopicConnectionFactory foreignTopicConnectionFactory) |
void |
setOutboundTopicConnectionFactoryName(java.lang.String foreignTopicConnectionFactoryName) |
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 JmsTopicConnector()
public boolean init()
init
in class JmsConnector
public InboundTopicBridge[] getInboundTopicBridges()
public void setInboundTopicBridges(InboundTopicBridge[] inboundTopicBridges)
inboundTopicBridges
- The inboundTopicBridges to set.public OutboundTopicBridge[] getOutboundTopicBridges()
public void setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges)
outboundTopicBridges
- The outboundTopicBridges to set.public javax.jms.TopicConnectionFactory getLocalTopicConnectionFactory()
public void setLocalTopicConnectionFactory(javax.jms.TopicConnectionFactory localConnectionFactory)
localTopicConnectionFactory
- The localTopicConnectionFactory to
set.public javax.jms.TopicConnectionFactory getOutboundTopicConnectionFactory()
public java.lang.String getOutboundTopicConnectionFactoryName()
public void setOutboundTopicConnectionFactoryName(java.lang.String foreignTopicConnectionFactoryName)
outboundTopicConnectionFactoryName
- The
outboundTopicConnectionFactoryName to set.public java.lang.String getLocalConnectionFactoryName()
public void setLocalConnectionFactoryName(java.lang.String localConnectionFactoryName)
localConnectionFactoryName
- The localConnectionFactoryName to set.public javax.jms.TopicConnection getLocalTopicConnection()
public void setLocalTopicConnection(javax.jms.TopicConnection localTopicConnection)
localTopicConnection
- The localTopicConnection to set.public javax.jms.TopicConnection getOutboundTopicConnection()
public void setOutboundTopicConnection(javax.jms.TopicConnection foreignTopicConnection)
outboundTopicConnection
- The outboundTopicConnection to set.public void setOutboundTopicConnectionFactory(javax.jms.TopicConnectionFactory foreignTopicConnectionFactory)
outboundTopicConnectionFactory
- The outboundTopicConnectionFactory
to set.public void restartProducerConnection() throws javax.naming.NamingException, javax.jms.JMSException
restartProducerConnection
in class JmsConnector
javax.naming.NamingException
javax.jms.JMSException
protected void initializeForeignTopicConnection() throws javax.naming.NamingException, javax.jms.JMSException
javax.naming.NamingException
javax.jms.JMSException
protected void initializeLocalTopicConnection() throws javax.naming.NamingException, javax.jms.JMSException
javax.naming.NamingException
javax.jms.JMSException
protected void initializeInboundJmsMessageConvertor()
protected void initializeOutboundJmsMessageConvertor()
protected void initializeInboundTopicBridges() throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundTopicBridges() 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.Topic createActiveMQTopic(javax.jms.TopicSession session, java.lang.String topicName) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Topic createForeignTopic(javax.jms.TopicSession session, java.lang.String topicName) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005-2012. All Rights Reserved.