Package 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:
MessageListener
,Service
public class InboundTopicBridge extends DestinationBridge
Create an Inbound Topic Bridge. By default this class uses the topic name for both the inbound and outbound topic. This behavior can be overridden however by using the setter methods to configure both the inbound and outboud topic names separately.
-
-
Field Summary
Fields Modifier and Type Field Description protected TopicConnection
consumerConnection
protected String
consumerName
protected TopicSession
consumerSession
protected Topic
consumerTopic
protected TopicPublisher
producer
protected TopicConnection
producerConnection
protected TopicSession
producerSession
protected Topic
producerTopic
protected String
selector
-
Fields inherited from class org.apache.activemq.network.jms.DestinationBridge
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
-
-
Constructor Summary
Constructors Constructor Description InboundTopicBridge()
Default ConstructorInboundTopicBridge(String inboundTopicName)
Constructor that takes a foreign destination as an argument
-
Method Summary
-
Methods inherited from class org.apache.activemq.network.jms.DestinationBridge
getConsumer, getJmsMessageConvertor, isDoHandleReplyTo, onMessage, processReplyToDestination, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, start
-
-
-
-
Field Detail
-
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
-
-
Constructor Detail
-
InboundTopicBridge
public InboundTopicBridge(String inboundTopicName)
Constructor that takes a foreign destination as an argument- Parameters:
inboundTopicName
-
-
InboundTopicBridge
public InboundTopicBridge()
Default Constructor
-
-
Method Detail
-
getInboundTopicName
public String getInboundTopicName()
- Returns:
- Returns the outboundTopicName.
-
setInboundTopicName
public void setInboundTopicName(String inboundTopicName)
Sets the topic name used for the inbound topic, if the outbound topic name has not been set, then this method uses the same name to configure the outbound topic name.- Parameters:
inboundTopicName
-
-
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 interfaceService
- Overrides:
stop
in classDestinationBridge
- Throws:
Exception
-
createConsumer
protected MessageConsumer createConsumer() throws JMSException
- Specified by:
createConsumer
in classDestinationBridge
- Throws:
JMSException
-
createProducer
protected MessageProducer createProducer() throws JMSException
- Specified by:
createProducer
in classDestinationBridge
- Throws:
JMSException
-
sendMessage
protected void sendMessage(Message message) throws JMSException
- Specified by:
sendMessage
in classDestinationBridge
- 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 consumerName.
-
setConsumerName
public void setConsumerName(String consumerName)
- Parameters:
consumerName
- The consumerName 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 classDestinationBridge
-
getConnectionForProducer
protected Connection getConnectionForProducer()
- Specified by:
getConnectionForProducer
in classDestinationBridge
-
-