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
Fields inherited from class org.apache.activemq.network.jms.JmsConnector |
connectionSerivce, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, replyToBridges, replyToDestinationCacheSize, started |
Methods inherited from class org.apache.activemq.network.jms.JmsConnector |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsTopicConnector
public JmsTopicConnector()
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.
initializeForeignConnection
protected void initializeForeignConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Description copied from class:
JmsConnector
- Performs the work of connection to the foreign side of the Connection.
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.
- Specified by:
initializeForeignConnection
in class JmsConnector
- Throws:
javax.naming.NamingException
javax.jms.JMSException
initializeLocalConnection
protected void initializeLocalConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Description copied from class:
JmsConnector
- Performs the work of connection to the local side of the Connection.
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.
- Specified by:
initializeLocalConnection
in class JmsConnector
- Throws:
javax.naming.NamingException
javax.jms.JMSException
initializeInboundDestinationBridgesOutboundSide
protected void initializeInboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeInboundDestinationBridgesLocalSide
protected void initializeInboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeOutboundDestinationBridgesOutboundSide
protected void initializeOutboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initializeOutboundDestinationBridgesLocalSide
protected void initializeOutboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection)
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 © 2005-2016. All Rights Reserved.