org.apache.activemq.network.jms
Class OutboundTopicBridge
java.lang.Object
org.apache.activemq.network.jms.DestinationBridge
org.apache.activemq.network.jms.OutboundTopicBridge
- All Implemented Interfaces:
- MessageListener, Service
public class OutboundTopicBridge
- extends DestinationBridge
Create an Outbound Topic Bridge
- Version:
- $Revision: 1.1.1.1 $
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 |
consumerTopic
protected Topic consumerTopic
producerTopic
protected Topic producerTopic
consumerSession
protected TopicSession consumerSession
producerSession
protected TopicSession producerSession
consumerName
protected String consumerName
selector
protected String selector
producer
protected TopicPublisher producer
consumerConnection
protected TopicConnection consumerConnection
producerConnection
protected TopicConnection producerConnection
OutboundTopicBridge
public OutboundTopicBridge(String outboundTopicName)
- Constructor that takes a foreign destination as an argument
- Parameters:
outboundTopicName
-
OutboundTopicBridge
public OutboundTopicBridge()
- Default Contructor
getOutboundTopicName
public String getOutboundTopicName()
- Returns:
- Returns the outboundTopicName.
setOutboundTopicName
public void setOutboundTopicName(String outboundTopicName)
- Parameters:
outboundTopicName
- The outboundTopicName to set.
getLocalTopicName
public String getLocalTopicName()
- Returns:
- the localTopicName
setLocalTopicName
public void setLocalTopicName(String localTopicName)
- Parameters:
localTopicName
- the localTopicName to set
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class DestinationBridge
- Throws:
Exception
createConsumer
protected MessageConsumer createConsumer()
throws JMSException
- Specified by:
createConsumer
in class DestinationBridge
- Throws:
JMSException
createProducer
protected MessageProducer createProducer()
throws JMSException
- Specified by:
createProducer
in class DestinationBridge
- Throws:
JMSException
sendMessage
protected void sendMessage(Message message)
throws JMSException
- Specified by:
sendMessage
in class DestinationBridge
- Throws:
JMSException
getConsumerConnection
public TopicConnection getConsumerConnection()
- Returns:
- Returns the consumerConnection.
setConsumerConnection
public void setConsumerConnection(TopicConnection consumerConnection)
- Parameters:
consumerConnection
- The consumerConnection to set.
getConsumerName
public String getConsumerName()
- Returns:
- Returns the subscriptionName.
setConsumerName
public void setConsumerName(String consumerName)
- Parameters:
subscriptionName
- The subscriptionName to set.
getConsumerTopic
public Topic getConsumerTopic()
- Returns:
- Returns the consumerTopic.
setConsumerTopic
public void setConsumerTopic(Topic consumerTopic)
- Parameters:
consumerTopic
- The consumerTopic to set.
getProducerConnection
public TopicConnection getProducerConnection()
- Returns:
- Returns the producerConnection.
setProducerConnection
public void setProducerConnection(TopicConnection producerConnection)
- Parameters:
producerConnection
- The producerConnection to set.
getProducerTopic
public Topic getProducerTopic()
- Returns:
- Returns the producerTopic.
setProducerTopic
public void setProducerTopic(Topic producerTopic)
- Parameters:
producerTopic
- The producerTopic to set.
getSelector
public String getSelector()
- Returns:
- Returns the selector.
setSelector
public void setSelector(String selector)
- Parameters:
selector
- The selector to set.
getConnnectionForConsumer
protected Connection getConnnectionForConsumer()
- Specified by:
getConnnectionForConsumer
in class DestinationBridge
getConnectionForProducer
protected Connection getConnectionForProducer()
- Specified by:
getConnectionForProducer
in class DestinationBridge
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.