org.apache.activemq.network.jms
Class JmsTopicConnector

java.lang.Object
  extended by org.apache.activemq.network.jms.JmsConnector
      extended by org.apache.activemq.network.jms.JmsTopicConnector
All Implemented Interfaces:
Service

public class JmsTopicConnector
extends JmsConnector

A Bridge to other JMS Topic providers


Field Summary
 
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
 
Constructor Summary
JmsTopicConnector()
           
 
Method Summary
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)
           
 
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
 

Constructor Detail

JmsTopicConnector

public JmsTopicConnector()
Method Detail

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 © 2005-2011. All Rights Reserved.