org.apache.activemq.network.jms
Class DestinationBridge
java.lang.Object
org.apache.activemq.network.jms.DestinationBridge
- All Implemented Interfaces:
- MessageListener, Service
- Direct Known Subclasses:
- InboundQueueBridge, InboundTopicBridge, OutboundQueueBridge, OutboundTopicBridge
public abstract class DestinationBridge
- extends Object
- implements Service, MessageListener
A Destination bridge is used to bridge between to different JMS systems
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
consumer
protected MessageConsumer consumer
started
protected AtomicBoolean started
jmsMessageConvertor
protected JmsMesageConvertor jmsMessageConvertor
doHandleReplyTo
protected boolean doHandleReplyTo
jmsConnector
protected JmsConnector jmsConnector
DestinationBridge
public DestinationBridge()
getConsumer
public MessageConsumer getConsumer()
- Returns:
- Returns the consumer.
setConsumer
public void setConsumer(MessageConsumer consumer)
- Parameters:
consumer
- The consumer to set.
setJmsConnector
public void setJmsConnector(JmsConnector connector)
- Parameters:
connector
-
getJmsMessageConvertor
public JmsMesageConvertor getJmsMessageConvertor()
- Returns:
- Returns the inboundMessageConvertor.
setJmsMessageConvertor
public void setJmsMessageConvertor(JmsMesageConvertor jmsMessageConvertor)
- Parameters:
jmsMessageConvertor
-
getMaximumRetries
public int getMaximumRetries()
setMaximumRetries
public void setMaximumRetries(int maximumRetries)
- Sets the maximum number of retries if a send fails before closing the
bridge
processReplyToDestination
protected Destination processReplyToDestination(Destination destination)
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
onMessage
public void onMessage(Message message)
- Specified by:
onMessage
in interface MessageListener
isDoHandleReplyTo
protected boolean isDoHandleReplyTo()
- Returns:
- Returns the doHandleReplyTo.
setDoHandleReplyTo
protected void setDoHandleReplyTo(boolean doHandleReplyTo)
- Parameters:
doHandleReplyTo
- The doHandleReplyTo to set.
createConsumer
protected abstract MessageConsumer createConsumer()
throws JMSException
- Throws:
JMSException
createProducer
protected abstract MessageProducer createProducer()
throws JMSException
- Throws:
JMSException
sendMessage
protected abstract void sendMessage(Message message)
throws JMSException
- Throws:
JMSException
getConnnectionForConsumer
protected abstract Connection getConnnectionForConsumer()
getConnectionForProducer
protected abstract Connection getConnectionForProducer()
restartProducer
protected void restartProducer()
throws JMSException,
NamingException
- Throws:
JMSException
NamingException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.