public class OutboundQueueBridge extends DestinationBridge
Modifier and Type | Field and Description |
---|---|
protected QueueConnection |
consumerConnection |
protected Queue |
consumerQueue |
protected QueueSession |
consumerSession |
protected QueueSender |
producer |
protected QueueConnection |
producerConnection |
protected Queue |
producerQueue |
protected 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 MessageConsumer |
createConsumer() |
protected MessageProducer |
createProducer() |
protected Connection |
getConnectionForProducer() |
protected Connection |
getConnnectionForConsumer() |
QueueConnection |
getConsumerConnection() |
Queue |
getConsumerQueue() |
String |
getLocalQueueName() |
String |
getOutboundQueueName() |
QueueConnection |
getProducerConnection() |
Queue |
getProducerQueue() |
String |
getSelector() |
protected void |
sendMessage(Message message) |
void |
setConsumerConnection(QueueConnection consumerConnection) |
void |
setConsumerQueue(Queue consumerQueue) |
void |
setLocalQueueName(String localQueueName) |
void |
setOutboundQueueName(String outboundQueueName)
Sets the name of the outbound queue name.
|
void |
setProducerConnection(QueueConnection producerConnection) |
void |
setProducerQueue(Queue producerQueue) |
void |
setSelector(String selector) |
void |
stop() |
getConsumer, getJmsMessageConvertor, isDoHandleReplyTo, onMessage, processReplyToDestination, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, start
protected Queue consumerQueue
protected Queue producerQueue
protected QueueSession consumerSession
protected QueueSession producerSession
protected QueueSender producer
protected QueueConnection consumerConnection
protected 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 MessageConsumer createConsumer() throws JMSException
createConsumer
in class DestinationBridge
JMSException
protected MessageProducer createProducer() throws JMSException
createProducer
in class DestinationBridge
JMSException
protected void sendMessage(Message message) throws JMSException
sendMessage
in class DestinationBridge
JMSException
public QueueConnection getConsumerConnection()
public void setConsumerConnection(QueueConnection consumerConnection)
consumerConnection
- The consumerConnection to set.public Queue getConsumerQueue()
public void setConsumerQueue(Queue consumerQueue)
consumerQueue
- The consumerQueue to set.public QueueConnection getProducerConnection()
public void setProducerConnection(QueueConnection producerConnection)
producerConnection
- The producerConnection to set.public Queue getProducerQueue()
public void setProducerQueue(Queue producerQueue)
producerQueue
- The producerQueue to set.public String getSelector()
public void setSelector(String selector)
selector
- The selector to set.protected Connection getConnnectionForConsumer()
getConnnectionForConsumer
in class DestinationBridge
protected Connection getConnectionForProducer()
getConnectionForProducer
in class DestinationBridge
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.