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

Version:
$Revision: 1.1.1.1 $

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  Topic createActiveMQTopic(TopicSession session, String topicName)
           
protected  Topic createForeignTopic(TopicSession session, String topicName)
           
protected  Destination createReplyToBridge(Destination destination, Connection replyToProducerConnection, Connection replyToConsumerConnection)
           
 InboundTopicBridge[] getInboundTopicBridges()
           
 String getLocalConnectionFactoryName()
           
 TopicConnection getLocalTopicConnection()
           
 TopicConnectionFactory getLocalTopicConnectionFactory()
           
 OutboundTopicBridge[] getOutboundTopicBridges()
           
 TopicConnection getOutboundTopicConnection()
           
 TopicConnectionFactory getOutboundTopicConnectionFactory()
           
 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(String localConnectionFactoryName)
           
 void setLocalTopicConnection(TopicConnection localTopicConnection)
           
 void setLocalTopicConnectionFactory(TopicConnectionFactory localConnectionFactory)
           
 void setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges)
           
 void setOutboundTopicConnection(TopicConnection foreignTopicConnection)
           
 void setOutboundTopicConnectionFactory(TopicConnectionFactory foreignTopicConnectionFactory)
           
 void setOutboundTopicConnectionFactoryName(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 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.