org.apache.activemq.network.jms
Class OutboundQueueBridge

java.lang.Object
  extended by org.apache.activemq.network.jms.DestinationBridge
      extended by org.apache.activemq.network.jms.OutboundQueueBridge
All Implemented Interfaces:
javax.jms.MessageListener, Service

public class OutboundQueueBridge
extends DestinationBridge

Create an Outbound Queue Bridge. By default the bridge uses the same name for both the inbound and outbound queues, however this can be altered by using the public setter methods to configure both inbound and outbound queue names.


Field Summary
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
           
 
Fields inherited from class org.apache.activemq.network.jms.DestinationBridge
consumer, doHandleReplyTo, jmsConnector, jmsMessageConvertor, started
 
Constructor Summary
OutboundQueueBridge()
          Default Constructor
OutboundQueueBridge(java.lang.String outboundQueueName)
          Constructor that takes a foreign destination as an argument
 
Method Summary
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 getLocalQueueName()
           
 java.lang.String getOutboundQueueName()
           
 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 setLocalQueueName(java.lang.String localQueueName)
           
 void setOutboundQueueName(java.lang.String outboundQueueName)
          Sets the name of the outbound queue name.
 void setProducerConnection(javax.jms.QueueConnection producerConnection)
           
 void setProducerQueue(javax.jms.Queue producerQueue)
           
 void setSelector(java.lang.String selector)
           
 void stop()
           
 
Methods inherited from class org.apache.activemq.network.jms.DestinationBridge
getConsumer, getJmsMessageConvertor, isDoHandleReplyTo, onMessage, processReplyToDestination, setConsumer, setDoHandleReplyTo, setJmsConnector, setJmsMessageConvertor, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

OutboundQueueBridge

public OutboundQueueBridge(java.lang.String outboundQueueName)
Constructor that takes a foreign destination as an argument

Parameters:
outboundQueueName -

OutboundQueueBridge

public OutboundQueueBridge()
Default Constructor

Method Detail

getOutboundQueueName

public java.lang.String getOutboundQueueName()
Returns:
Returns the outboundQueueName.

setOutboundQueueName

public void setOutboundQueueName(java.lang.String outboundQueueName)
Sets the name of the outbound queue name. If the inbound queue name has not been set already then this method uses the provided queue name to set the inbound topic name as well.

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 © 2005-2016. All Rights Reserved.