org.apache.activemq.network.jms
Class JmsTopicConnector
java.lang.Object
org.apache.activemq.network.jms.JmsConnector
org.apache.activemq.network.jms.JmsTopicConnector
- All Implemented Interfaces:
- Service
public class JmsTopicConnector
- extends JmsConnector
A Bridge to other JMS Topic providers
- Version:
- $Revision: 1.1.1.1 $
Fields inherited from class org.apache.activemq.network.jms.JmsConnector |
embeddedConnectionFactory, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localPassword, localUsername, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started |
Methods inherited from class org.apache.activemq.network.jms.JmsConnector |
addInboundBridge, addOutboundBridge, getInboundMessageConvertor, getJndiLocalTemplate, getJndiOutboundTemplate, getLocalPassword, getLocalUsername, getName, getOutboundMessageConvertor, getOutboundPassword, getOutboundUsername, getReplyToDestinationCacheSize, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalPassword, setLocalUsername, setName, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setReplyToDestinationCacheSize, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsTopicConnector
public JmsTopicConnector()
init
public boolean init()
- Overrides:
init
in class JmsConnector
getInboundTopicBridges
public InboundTopicBridge[] getInboundTopicBridges()
- Returns:
- Returns the inboundTopicBridges.
setInboundTopicBridges
public void setInboundTopicBridges(InboundTopicBridge[] inboundTopicBridges)
- Parameters:
inboundTopicBridges
- The inboundTopicBridges to set.
getOutboundTopicBridges
public OutboundTopicBridge[] getOutboundTopicBridges()
- Returns:
- Returns the outboundTopicBridges.
setOutboundTopicBridges
public void setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges)
- Parameters:
outboundTopicBridges
- The outboundTopicBridges to set.
getLocalTopicConnectionFactory
public javax.jms.TopicConnectionFactory getLocalTopicConnectionFactory()
- Returns:
- Returns the localTopicConnectionFactory.
setLocalTopicConnectionFactory
public void setLocalTopicConnectionFactory(javax.jms.TopicConnectionFactory localConnectionFactory)
- Parameters:
localTopicConnectionFactory
- The localTopicConnectionFactory to set.
getOutboundTopicConnectionFactory
public javax.jms.TopicConnectionFactory getOutboundTopicConnectionFactory()
- Returns:
- Returns the outboundTopicConnectionFactory.
getOutboundTopicConnectionFactoryName
public java.lang.String getOutboundTopicConnectionFactoryName()
- Returns:
- Returns the outboundTopicConnectionFactoryName.
setOutboundTopicConnectionFactoryName
public void setOutboundTopicConnectionFactoryName(java.lang.String foreignTopicConnectionFactoryName)
- Parameters:
outboundTopicConnectionFactoryName
- The outboundTopicConnectionFactoryName 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.
getLocalTopicConnection
public javax.jms.TopicConnection getLocalTopicConnection()
- Returns:
- Returns the localTopicConnection.
setLocalTopicConnection
public void setLocalTopicConnection(javax.jms.TopicConnection localTopicConnection)
- Parameters:
localTopicConnection
- The localTopicConnection to set.
getOutboundTopicConnection
public javax.jms.TopicConnection getOutboundTopicConnection()
- Returns:
- Returns the outboundTopicConnection.
setOutboundTopicConnection
public void setOutboundTopicConnection(javax.jms.TopicConnection foreignTopicConnection)
- Parameters:
outboundTopicConnection
- The outboundTopicConnection to set.
setOutboundTopicConnectionFactory
public void setOutboundTopicConnectionFactory(javax.jms.TopicConnectionFactory foreignTopicConnectionFactory)
- Parameters:
outboundTopicConnectionFactory
- The outboundTopicConnectionFactory to set.
restartProducerConnection
public void restartProducerConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Specified by:
restartProducerConnection
in class JmsConnector
- Throws:
javax.naming.NamingException
javax.jms.JMSException
initializeForeignTopicConnection
protected void initializeForeignTopicConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Throws:
javax.naming.NamingException
javax.jms.JMSException
initializeLocalTopicConnection
protected void initializeLocalTopicConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Throws:
javax.naming.NamingException
javax.jms.JMSException
initializeInboundJmsMessageConvertor
protected void initializeInboundJmsMessageConvertor()
initializeOutboundJmsMessageConvertor
protected void initializeOutboundJmsMessageConvertor()
initializeInboundTopicBridges
protected void initializeInboundTopicBridges()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeOutboundTopicBridges
protected void initializeOutboundTopicBridges()
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
createActiveMQTopic
protected javax.jms.Topic createActiveMQTopic(javax.jms.TopicSession session,
java.lang.String topicName)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createForeignTopic
protected javax.jms.Topic createForeignTopic(javax.jms.TopicSession session,
java.lang.String topicName)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
Copyright © 2009 Apache Software Foundation. All Rights Reserved.