public class InboundTopicBridge extends DestinationBridge
Modifier and Type | Field and Description |
---|---|
protected javax.jms.TopicConnection |
consumerConnection |
protected 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 String |
selector |
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
Constructor and Description |
---|
InboundTopicBridge()
Default Constructor
|
InboundTopicBridge(String inboundTopicName)
Constructor that takes a foreign destination as an argument
|
Modifier and Type | Method and Description |
---|---|
protected javax.jms.MessageConsumer |
createConsumer() |
protected javax.jms.MessageProducer |
createProducer() |
protected javax.jms.Connection |
getConnectionForProducer() |
protected javax.jms.Connection |
getConnnectionForConsumer() |
javax.jms.TopicConnection |
getConsumerConnection() |
String |
getConsumerName() |
javax.jms.Topic |
getConsumerTopic() |
String |
getInboundTopicName() |
String |
getLocalTopicName() |
javax.jms.TopicConnection |
getProducerConnection() |
javax.jms.Topic |
getProducerTopic() |
String |
getSelector() |
protected void |
sendMessage(javax.jms.Message message) |
void |
setConsumerConnection(javax.jms.TopicConnection consumerConnection) |
void |
setConsumerName(String consumerName) |
void |
setConsumerTopic(javax.jms.Topic consumerTopic) |
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.
|
void |
setLocalTopicName(String localTopicName) |
void |
setProducerConnection(javax.jms.TopicConnection producerConnection) |
void |
setProducerTopic(javax.jms.Topic producerTopic) |
void |
setSelector(String selector) |
void |
stop() |
getConsumer, getJmsMessageConvertor, isDoHandleReplyTo, onMessage, processReplyToDestination, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, start
protected javax.jms.Topic consumerTopic
protected javax.jms.Topic producerTopic
protected javax.jms.TopicSession consumerSession
protected javax.jms.TopicSession producerSession
protected String consumerName
protected String selector
protected javax.jms.TopicPublisher producer
protected javax.jms.TopicConnection consumerConnection
protected javax.jms.TopicConnection producerConnection
public InboundTopicBridge(String inboundTopicName)
inboundTopicName
- public InboundTopicBridge()
public String getInboundTopicName()
public void setInboundTopicName(String inboundTopicName)
inboundTopicName
- public String getLocalTopicName()
public void setLocalTopicName(String localTopicName)
localTopicName
- the localTopicName to setpublic void stop() throws Exception
stop
in interface Service
stop
in class DestinationBridge
Exception
protected javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
createConsumer
in class DestinationBridge
javax.jms.JMSException
protected javax.jms.MessageProducer createProducer() throws javax.jms.JMSException
createProducer
in class DestinationBridge
javax.jms.JMSException
protected void sendMessage(javax.jms.Message message) throws javax.jms.JMSException
sendMessage
in class DestinationBridge
javax.jms.JMSException
public javax.jms.TopicConnection getConsumerConnection()
public void setConsumerConnection(javax.jms.TopicConnection consumerConnection)
consumerConnection
- The consumerConnection to set.public String getConsumerName()
public void setConsumerName(String consumerName)
subscriptionName
- The subscriptionName to set.public javax.jms.Topic getConsumerTopic()
public void setConsumerTopic(javax.jms.Topic consumerTopic)
consumerTopic
- The consumerTopic to set.public javax.jms.TopicConnection getProducerConnection()
public void setProducerConnection(javax.jms.TopicConnection producerConnection)
producerConnection
- The producerConnection to set.public javax.jms.Topic getProducerTopic()
public void setProducerTopic(javax.jms.Topic producerTopic)
producerTopic
- The producerTopic to set.public String getSelector()
public void setSelector(String selector)
selector
- The selector to set.protected javax.jms.Connection getConnnectionForConsumer()
getConnnectionForConsumer
in class DestinationBridge
protected javax.jms.Connection getConnectionForProducer()
getConnectionForProducer
in class DestinationBridge
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.