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, startprotected 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 Servicestop in class DestinationBridgeExceptionprotected MessageConsumer createConsumer() throws JMSException
createConsumer in class DestinationBridgeJMSExceptionprotected MessageProducer createProducer() throws JMSException
createProducer in class DestinationBridgeJMSExceptionprotected void sendMessage(Message message) throws JMSException
sendMessage in class DestinationBridgeJMSExceptionpublic 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 DestinationBridgeprotected Connection getConnectionForProducer()
getConnectionForProducer in class DestinationBridgeCopyright © 2005–2016 FuseSource, Corp.. All rights reserved.