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, localClientId, localPassword, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started |
Methods inherited from class org.apache.activemq.network.jms.JmsConnector |
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 |
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 TopicConnectionFactory getLocalTopicConnectionFactory()
- Returns:
- Returns the localTopicConnectionFactory.
setLocalTopicConnectionFactory
public void setLocalTopicConnectionFactory(TopicConnectionFactory localConnectionFactory)
- Parameters:
localTopicConnectionFactory
- The localTopicConnectionFactory to
set.
getOutboundTopicConnectionFactory
public TopicConnectionFactory getOutboundTopicConnectionFactory()
- Returns:
- Returns the outboundTopicConnectionFactory.
getOutboundTopicConnectionFactoryName
public String getOutboundTopicConnectionFactoryName()
- Returns:
- Returns the outboundTopicConnectionFactoryName.
setOutboundTopicConnectionFactoryName
public void setOutboundTopicConnectionFactoryName(String foreignTopicConnectionFactoryName)
- Parameters:
outboundTopicConnectionFactoryName
- The
outboundTopicConnectionFactoryName to set.
getLocalConnectionFactoryName
public String getLocalConnectionFactoryName()
- Returns:
- Returns the localConnectionFactoryName.
setLocalConnectionFactoryName
public void setLocalConnectionFactoryName(String localConnectionFactoryName)
- Parameters:
localConnectionFactoryName
- The localConnectionFactoryName to set.
getLocalTopicConnection
public TopicConnection getLocalTopicConnection()
- Returns:
- Returns the localTopicConnection.
setLocalTopicConnection
public void setLocalTopicConnection(TopicConnection localTopicConnection)
- Parameters:
localTopicConnection
- The localTopicConnection to set.
getOutboundTopicConnection
public TopicConnection getOutboundTopicConnection()
- Returns:
- Returns the outboundTopicConnection.
setOutboundTopicConnection
public void setOutboundTopicConnection(TopicConnection foreignTopicConnection)
- Parameters:
outboundTopicConnection
- The outboundTopicConnection to set.
setOutboundTopicConnectionFactory
public void setOutboundTopicConnectionFactory(TopicConnectionFactory foreignTopicConnectionFactory)
- Parameters:
outboundTopicConnectionFactory
- The outboundTopicConnectionFactory
to set.
restartProducerConnection
public void restartProducerConnection()
throws NamingException,
JMSException
- Specified by:
restartProducerConnection
in class JmsConnector
- Throws:
NamingException
JMSException
initializeForeignTopicConnection
protected void initializeForeignTopicConnection()
throws NamingException,
JMSException
- Throws:
NamingException
JMSException
initializeLocalTopicConnection
protected void initializeLocalTopicConnection()
throws NamingException,
JMSException
- Throws:
NamingException
JMSException
initializeInboundJmsMessageConvertor
protected void initializeInboundJmsMessageConvertor()
initializeOutboundJmsMessageConvertor
protected void initializeOutboundJmsMessageConvertor()
initializeInboundTopicBridges
protected void initializeInboundTopicBridges()
throws JMSException
- Throws:
JMSException
initializeOutboundTopicBridges
protected void initializeOutboundTopicBridges()
throws JMSException
- Throws:
JMSException
createReplyToBridge
protected Destination createReplyToBridge(Destination destination,
Connection replyToProducerConnection,
Connection replyToConsumerConnection)
- Specified by:
createReplyToBridge
in class JmsConnector
createActiveMQTopic
protected Topic createActiveMQTopic(TopicSession session,
String topicName)
throws JMSException
- Throws:
JMSException
createForeignTopic
protected Topic createForeignTopic(TopicSession session,
String topicName)
throws JMSException
- Throws:
JMSException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.