org.apache.activemq.network.jms
Class OutboundQueueBridge
java.lang.Object
org.apache.activemq.network.jms.DestinationBridge
org.apache.activemq.network.jms.OutboundQueueBridge
- All Implemented Interfaces:
- javax.jms.MessageListener, Service
public class OutboundQueueBridge
- extends DestinationBridge
Create an Outbound Queue Bridge
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class org.apache.activemq.network.jms.DestinationBridge |
getConsumer, getJmsMessageConvertor, getMaximumRetries, isDoHandleReplyTo, onMessage, processReplyToDestination, restartProducer, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, setMaximumRetries, start |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
consumerQueue
protected javax.jms.Queue consumerQueue
producerQueue
protected javax.jms.Queue producerQueue
consumerSession
protected javax.jms.QueueSession consumerSession
producerSession
protected javax.jms.QueueSession producerSession
selector
protected java.lang.String selector
producer
protected javax.jms.QueueSender producer
consumerConnection
protected javax.jms.QueueConnection consumerConnection
producerConnection
protected javax.jms.QueueConnection producerConnection
OutboundQueueBridge
public OutboundQueueBridge(java.lang.String outboundQueueName)
- Constructor that takes a foreign destination as an argument
- Parameters:
outboundQueueName
-
OutboundQueueBridge
public OutboundQueueBridge()
- Default Contructor
getOutboundQueueName
public java.lang.String getOutboundQueueName()
- Returns:
- Returns the outboundQueueName.
setOutboundQueueName
public void setOutboundQueueName(java.lang.String outboundQueueName)
- Parameters:
outboundQueueName
- The outboundQueueName to set.
getLocalQueueName
public java.lang.String getLocalQueueName()
- Returns:
- the localQueueName
setLocalQueueName
public void setLocalQueueName(java.lang.String localQueueName)
- Parameters:
localQueueName
- the localQueueName to set
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class DestinationBridge
- Throws:
java.lang.Exception
createConsumer
protected javax.jms.MessageConsumer createConsumer()
throws javax.jms.JMSException
- Specified by:
createConsumer
in class DestinationBridge
- Throws:
javax.jms.JMSException
createProducer
protected javax.jms.MessageProducer createProducer()
throws javax.jms.JMSException
- Specified by:
createProducer
in class DestinationBridge
- Throws:
javax.jms.JMSException
sendMessage
protected void sendMessage(javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
sendMessage
in class DestinationBridge
- Throws:
javax.jms.JMSException
getConsumerConnection
public javax.jms.QueueConnection getConsumerConnection()
- Returns:
- Returns the consumerConnection.
setConsumerConnection
public void setConsumerConnection(javax.jms.QueueConnection consumerConnection)
- Parameters:
consumerConnection
- The consumerConnection to set.
getConsumerQueue
public javax.jms.Queue getConsumerQueue()
- Returns:
- Returns the consumerQueue.
setConsumerQueue
public void setConsumerQueue(javax.jms.Queue consumerQueue)
- Parameters:
consumerQueue
- The consumerQueue to set.
getProducerConnection
public javax.jms.QueueConnection getProducerConnection()
- Returns:
- Returns the producerConnection.
setProducerConnection
public void setProducerConnection(javax.jms.QueueConnection producerConnection)
- Parameters:
producerConnection
- The producerConnection to set.
getProducerQueue
public javax.jms.Queue getProducerQueue()
- Returns:
- Returns the producerQueue.
setProducerQueue
public void setProducerQueue(javax.jms.Queue producerQueue)
- Parameters:
producerQueue
- The producerQueue to set.
getSelector
public java.lang.String getSelector()
- Returns:
- Returns the selector.
setSelector
public void setSelector(java.lang.String selector)
- Parameters:
selector
- The selector to set.
getConnnectionForConsumer
protected javax.jms.Connection getConnnectionForConsumer()
- Specified by:
getConnnectionForConsumer
in class DestinationBridge
getConnectionForProducer
protected javax.jms.Connection getConnectionForProducer()
- Specified by:
getConnectionForProducer
in class DestinationBridge
Copyright © 2011 Apache Software Foundation. All Rights Reserved.