org.apache.activemq.network.jms
Class InboundTopicBridge
java.lang.Object
org.apache.activemq.network.jms.DestinationBridge
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 $
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 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
InboundTopicBridge
public InboundTopicBridge(java.lang.String inboundTopicName)
- Constructor that takes a foriegn destination as an argument
- Parameters:
inboundTopicName
-
InboundTopicBridge
public InboundTopicBridge()
- Default Contructor
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 © 2011 Apache Software Foundation. All Rights Reserved.