public class OutboundQueueBridge extends DestinationBridge
Modifier and Type | Field and Description |
---|---|
protected javax.jms.QueueConnection |
consumerConnection |
protected javax.jms.Queue |
consumerQueue |
protected javax.jms.QueueSession |
consumerSession |
protected javax.jms.QueueSender |
producer |
protected javax.jms.QueueConnection |
producerConnection |
protected javax.jms.Queue |
producerQueue |
protected javax.jms.QueueSession |
producerSession |
protected String |
selector |
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
Constructor and Description |
---|
OutboundQueueBridge()
Default Constructor
|
OutboundQueueBridge(String outboundQueueName)
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.QueueConnection |
getConsumerConnection() |
javax.jms.Queue |
getConsumerQueue() |
String |
getLocalQueueName() |
String |
getOutboundQueueName() |
javax.jms.QueueConnection |
getProducerConnection() |
javax.jms.Queue |
getProducerQueue() |
String |
getSelector() |
protected void |
sendMessage(javax.jms.Message message) |
void |
setConsumerConnection(javax.jms.QueueConnection consumerConnection) |
void |
setConsumerQueue(javax.jms.Queue consumerQueue) |
void |
setLocalQueueName(String localQueueName) |
void |
setOutboundQueueName(String outboundQueueName)
Sets the name of the outbound queue name.
|
void |
setProducerConnection(javax.jms.QueueConnection producerConnection) |
void |
setProducerQueue(javax.jms.Queue producerQueue) |
void |
setSelector(String selector) |
void |
stop() |
getConsumer, getJmsMessageConvertor, isDoHandleReplyTo, onMessage, processReplyToDestination, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, start
protected javax.jms.Queue consumerQueue
protected javax.jms.Queue producerQueue
protected javax.jms.QueueSession consumerSession
protected javax.jms.QueueSession producerSession
protected String selector
protected javax.jms.QueueSender producer
protected javax.jms.QueueConnection consumerConnection
protected javax.jms.QueueConnection producerConnection
public OutboundQueueBridge(String outboundQueueName)
outboundQueueName
- public OutboundQueueBridge()
public String getOutboundQueueName()
public void setOutboundQueueName(String outboundQueueName)
outboundQueueName
- The outboundQueueName to set.public String getLocalQueueName()
public void setLocalQueueName(String localQueueName)
localQueueName
- the localQueueName 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.QueueConnection getConsumerConnection()
public void setConsumerConnection(javax.jms.QueueConnection consumerConnection)
consumerConnection
- The consumerConnection to set.public javax.jms.Queue getConsumerQueue()
public void setConsumerQueue(javax.jms.Queue consumerQueue)
consumerQueue
- The consumerQueue to set.public javax.jms.QueueConnection getProducerConnection()
public void setProducerConnection(javax.jms.QueueConnection producerConnection)
producerConnection
- The producerConnection to set.public javax.jms.Queue getProducerQueue()
public void setProducerQueue(javax.jms.Queue producerQueue)
producerQueue
- The producerQueue 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–2014 The Apache Software Foundation. All rights reserved.