org.apache.activemq.network.jms
Class InboundTopicBridge

java.lang.Object
  extended by org.apache.activemq.network.jms.DestinationBridge
      extended by org.apache.activemq.network.jms.InboundTopicBridge
All Implemented Interfaces:
javax.jms.MessageListener, Service

public class InboundTopicBridge
extends DestinationBridge

Create an Inbound Topic Bridge

Version:
$Revision: 1.1.1.1 $

Field Summary
protected  javax.jms.TopicConnection consumerConnection
           
protected  java.lang.String consumerName
           
protected  javax.jms.TopicSession consumerSession
           
protected  javax.jms.Topic consumerTopic
           
protected  javax.jms.TopicPublisher producer
           
protected  javax.jms.TopicConnection producerConnection
           
protected  javax.jms.TopicSession producerSession
           
protected  javax.jms.Topic producerTopic
           
protected  java.lang.String selector
           
 
Fields inherited from class org.apache.activemq.network.jms.DestinationBridge
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
 
Constructor Summary
InboundTopicBridge()
          Default Contructor
InboundTopicBridge(java.lang.String inboundTopicName)
          Constructor that takes a foriegn destination as an argument
 
Method Summary
protected  javax.jms.MessageConsumer createConsumer()
           
protected  javax.jms.MessageProducer createProducer()
           
protected  javax.jms.Connection getConnectionForProducer()
           
protected  javax.jms.Connection getConnnectionForConsumer()
           
 javax.jms.TopicConnection getConsumerConnection()
           
 java.lang.String getConsumerName()
           
 javax.jms.Topic getConsumerTopic()
           
 java.lang.String getInboundTopicName()
           
 java.lang.String getLocalTopicName()
           
 javax.jms.TopicConnection getProducerConnection()
           
 javax.jms.Topic getProducerTopic()
           
 java.lang.String getSelector()
           
protected  void sendMessage(javax.jms.Message message)
           
 void setConsumerConnection(javax.jms.TopicConnection consumerConnection)
           
 void setConsumerName(java.lang.String consumerName)
           
 void setConsumerTopic(javax.jms.Topic consumerTopic)
           
 void setInboundTopicName(java.lang.String inboundTopicName)
           
 void setLocalTopicName(java.lang.String localTopicName)
           
 void setProducerConnection(javax.jms.TopicConnection producerConnection)
           
 void setProducerTopic(javax.jms.Topic producerTopic)
           
 void setSelector(java.lang.String selector)
           
 void stop()
           
 
Methods inherited from class org.apache.activemq.network.jms.DestinationBridge
getConsumer, getJmsMessageConvertor, getMaximumRetries, isDoHandleReplyTo, onMessage, processReplyToDestination, restartProducer, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, setMaximumRetries, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

consumerTopic

protected javax.jms.Topic consumerTopic

producerTopic

protected javax.jms.Topic producerTopic

consumerSession

protected javax.jms.TopicSession consumerSession

producerSession

protected javax.jms.TopicSession producerSession

consumerName

protected java.lang.String consumerName

selector

protected java.lang.String selector

producer

protected javax.jms.TopicPublisher producer

consumerConnection

protected javax.jms.TopicConnection consumerConnection

producerConnection

protected javax.jms.TopicConnection producerConnection
Constructor Detail

InboundTopicBridge

public InboundTopicBridge(java.lang.String inboundTopicName)
Constructor that takes a foriegn destination as an argument

Parameters:
inboundTopicName -

InboundTopicBridge

public InboundTopicBridge()
Default Contructor

Method Detail

getInboundTopicName

public java.lang.String getInboundTopicName()
Returns:
Returns the outboundTopicName.

setInboundTopicName

public void setInboundTopicName(java.lang.String inboundTopicName)
Parameters:
inboundTopicName -

getLocalTopicName

public java.lang.String getLocalTopicName()
Returns:
the localTopicName

setLocalTopicName

public void setLocalTopicName(java.lang.String localTopicName)
Parameters:
localTopicName - the localTopicName to set

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Overrides:
stop in class DestinationBridge
Throws:
java.lang.Exception

createConsumer

protected javax.jms.MessageConsumer createConsumer()
                                            throws javax.jms.JMSException
Specified by:
createConsumer in class DestinationBridge
Throws:
javax.jms.JMSException

createProducer

protected javax.jms.MessageProducer createProducer()
                                            throws javax.jms.JMSException
Specified by:
createProducer in class DestinationBridge
Throws:
javax.jms.JMSException

sendMessage

protected void sendMessage(javax.jms.Message message)
                    throws javax.jms.JMSException
Specified by:
sendMessage in class DestinationBridge
Throws:
javax.jms.JMSException

getConsumerConnection

public javax.jms.TopicConnection getConsumerConnection()
Returns:
Returns the consumerConnection.

setConsumerConnection

public void setConsumerConnection(javax.jms.TopicConnection consumerConnection)
Parameters:
consumerConnection - The consumerConnection to set.

getConsumerName

public java.lang.String getConsumerName()
Returns:
Returns the subscriptionName.

setConsumerName

public void setConsumerName(java.lang.String consumerName)
Parameters:
subscriptionName - The subscriptionName to set.

getConsumerTopic

public javax.jms.Topic getConsumerTopic()
Returns:
Returns the consumerTopic.

setConsumerTopic

public void setConsumerTopic(javax.jms.Topic consumerTopic)
Parameters:
consumerTopic - The consumerTopic to set.

getProducerConnection

public javax.jms.TopicConnection getProducerConnection()
Returns:
Returns the producerConnection.

setProducerConnection

public void setProducerConnection(javax.jms.TopicConnection producerConnection)
Parameters:
producerConnection - The producerConnection to set.

getProducerTopic

public javax.jms.Topic getProducerTopic()
Returns:
Returns the producerTopic.

setProducerTopic

public void setProducerTopic(javax.jms.Topic producerTopic)
Parameters:
producerTopic - The producerTopic to set.

getSelector

public java.lang.String getSelector()
Returns:
Returns the selector.

setSelector

public void setSelector(java.lang.String selector)
Parameters:
selector - The selector to set.

getConnnectionForConsumer

protected javax.jms.Connection getConnnectionForConsumer()
Specified by:
getConnnectionForConsumer in class DestinationBridge

getConnectionForProducer

protected javax.jms.Connection getConnectionForProducer()
Specified by:
getConnectionForProducer in class DestinationBridge


Copyright © 2010 Apache Software Foundation. All Rights Reserved.