org.apache.activemq.network.jms
Class InboundQueueBridge
java.lang.Object
org.apache.activemq.network.jms.DestinationBridge
org.apache.activemq.network.jms.InboundQueueBridge
- All Implemented Interfaces:
- MessageListener, Service
public class InboundQueueBridge
- extends DestinationBridge
Create an Inbound 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 Queue consumerQueue
producerQueue
protected Queue producerQueue
consumerSession
protected QueueSession consumerSession
producerSession
protected QueueSession producerSession
selector
protected String selector
producer
protected QueueSender producer
consumerConnection
protected QueueConnection consumerConnection
producerConnection
protected QueueConnection producerConnection
InboundQueueBridge
public InboundQueueBridge(String inboundQueueName)
- Constructor that takes a foriegn destination as an argument
- Parameters:
inboundQueueName
-
InboundQueueBridge
public InboundQueueBridge()
- Default Contructor
getInboundQueueName
public String getInboundQueueName()
- Returns:
- Returns the inboundQueueName.
setInboundQueueName
public void setInboundQueueName(String inboundQueueName)
- Parameters:
inboundQueueName
- The inboundQueueName to set.
getLocalQueueName
public String getLocalQueueName()
- Returns:
- the localQueueName
setLocalQueueName
public void setLocalQueueName(String localQueueName)
- Parameters:
localQueueName
- the localQueueName to set
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class DestinationBridge
- Throws:
Exception
createConsumer
protected MessageConsumer createConsumer()
throws JMSException
- Specified by:
createConsumer
in class DestinationBridge
- Throws:
JMSException
createProducer
protected MessageProducer createProducer()
throws JMSException
- Specified by:
createProducer
in class DestinationBridge
- Throws:
JMSException
sendMessage
protected void sendMessage(Message message)
throws JMSException
- Specified by:
sendMessage
in class DestinationBridge
- Throws:
JMSException
getConsumerConnection
public QueueConnection getConsumerConnection()
- Returns:
- Returns the consumerConnection.
setConsumerConnection
public void setConsumerConnection(QueueConnection consumerConnection)
- Parameters:
consumerConnection
- The consumerConnection to set.
getConsumerQueue
public Queue getConsumerQueue()
- Returns:
- Returns the consumerQueue.
setConsumerQueue
public void setConsumerQueue(Queue consumerQueue)
- Parameters:
consumerQueue
- The consumerQueue to set.
getProducerConnection
public QueueConnection getProducerConnection()
- Returns:
- Returns the producerConnection.
setProducerConnection
public void setProducerConnection(QueueConnection producerConnection)
- Parameters:
producerConnection
- The producerConnection to set.
getProducerQueue
public Queue getProducerQueue()
- Returns:
- Returns the producerQueue.
setProducerQueue
public void setProducerQueue(Queue producerQueue)
- Parameters:
producerQueue
- The producerQueue to set.
getSelector
public String getSelector()
- Returns:
- Returns the selector.
setSelector
public void setSelector(String selector)
- Parameters:
selector
- The selector to set.
getConnnectionForConsumer
protected Connection getConnnectionForConsumer()
- Specified by:
getConnnectionForConsumer
in class DestinationBridge
getConnectionForProducer
protected Connection getConnectionForProducer()
- Specified by:
getConnectionForProducer
in class DestinationBridge
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.