org.apache.activemq.network.jms
Class SimpleJmsTopicConnector

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

public class SimpleJmsTopicConnector
extends JmsConnector

A Bridge to other JMS Topic providers


Field Summary
 
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, preferJndiDestinationLookup, replyToBridges, replyToDestinationCacheSize, started
 
Constructor Summary
SimpleJmsTopicConnector()
           
 
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()
           
protected  void initializeForeignConnection()
          Performs the work of connection to the foreign side of the Connection.
protected  void initializeInboundDestinationBridgesLocalSide(TopicConnection connection)
           
protected  void initializeInboundDestinationBridgesOutboundSide(TopicConnection connection)
           
protected  void initializeLocalConnection()
          Performs the work of connection to the local side of the Connection.
protected  void initializeOutboundDestinationBridgesLocalSide(TopicConnection connection)
           
protected  void initializeOutboundDestinationBridgesOutboundSide(TopicConnection connection)
           
 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, doConnectorInit, getForeignConnection, getInboundMessageConvertor, getJndiLocalTemplate, getJndiOutboundTemplate, getLocalClientId, getLocalConnection, getLocalPassword, getLocalUsername, getName, getOutboundClientId, getOutboundMessageConvertor, getOutboundPassword, getOutboundUsername, getReconnectionPolicy, getReplyToDestinationCacheSize, init, isConnected, isFailed, isPreferJndiDestinationLookup, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setPreferJndiDestinationLookup, setReconnectionPolicy, setReplyToDestinationCacheSize, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SimpleJmsTopicConnector

public SimpleJmsTopicConnector()
Method Detail

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.

initializeForeignConnection

protected void initializeForeignConnection()
                                    throws NamingException,
                                           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:
NamingException
JMSException

initializeLocalConnection

protected void initializeLocalConnection()
                                  throws NamingException,
                                         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:
NamingException
JMSException

initializeInboundDestinationBridgesOutboundSide

protected void initializeInboundDestinationBridgesOutboundSide(TopicConnection connection)
                                                        throws JMSException
Throws:
JMSException

initializeInboundDestinationBridgesLocalSide

protected void initializeInboundDestinationBridgesLocalSide(TopicConnection connection)
                                                     throws JMSException
Throws:
JMSException

initializeOutboundDestinationBridgesOutboundSide

protected void initializeOutboundDestinationBridgesOutboundSide(TopicConnection connection)
                                                         throws JMSException
Throws:
JMSException

initializeOutboundDestinationBridgesLocalSide

protected void initializeOutboundDestinationBridgesLocalSide(TopicConnection connection)
                                                      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-2013 The Apache Software Foundation. All Rights Reserved.