org.apache.activemq.network.jms
public class InboundQueueBridge 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 java.lang.String |
selector |
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
Constructor and Description |
---|
InboundQueueBridge()
Default Constructor
|
InboundQueueBridge(java.lang.String inboundQueueName)
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() |
java.lang.String |
getInboundQueueName() |
java.lang.String |
getLocalQueueName() |
javax.jms.QueueConnection |
getProducerConnection() |
javax.jms.Queue |
getProducerQueue() |
java.lang.String |
getSelector() |
protected void |
sendMessage(javax.jms.Message message) |
void |
setConsumerConnection(javax.jms.QueueConnection consumerConnection) |
void |
setConsumerQueue(javax.jms.Queue consumerQueue) |
void |
setInboundQueueName(java.lang.String inboundQueueName)
Sets the queue name used for the inbound queue, if the outbound queue
name has not been set, then this method uses the same name to configure
the outbound queue name.
|
void |
setLocalQueueName(java.lang.String localQueueName) |
void |
setProducerConnection(javax.jms.QueueConnection producerConnection) |
void |
setProducerQueue(javax.jms.Queue producerQueue) |
void |
setSelector(java.lang.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 java.lang.String selector
protected javax.jms.QueueSender producer
protected javax.jms.QueueConnection consumerConnection
protected javax.jms.QueueConnection producerConnection
public InboundQueueBridge(java.lang.String inboundQueueName)
inboundQueueName
- public InboundQueueBridge()
public java.lang.String getInboundQueueName()
public void setInboundQueueName(java.lang.String inboundQueueName)
inboundQueueName
- The inboundQueueName to set.public java.lang.String getLocalQueueName()
public void setLocalQueueName(java.lang.String localQueueName)
localQueueName
- the localQueueName to setpublic void stop() throws java.lang.Exception
stop
in interface Service
stop
in class DestinationBridge
java.lang.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 java.lang.String getSelector()
public void setSelector(java.lang.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. All Rights Reserved.