public abstract class DestinationBridge extends Object implements Service, javax.jms.MessageListener
Modifier and Type | Field and Description |
---|---|
protected javax.jms.MessageConsumer |
consumer |
protected boolean |
doHandleReplyTo |
protected JmsConnector |
jmsConnector |
protected JmsMesageConvertor |
jmsMessageConvertor |
protected AtomicBoolean |
started |
Constructor and Description |
---|
DestinationBridge() |
Modifier and Type | Method and Description |
---|---|
protected abstract javax.jms.MessageConsumer |
createConsumer() |
protected abstract javax.jms.MessageProducer |
createProducer() |
protected abstract javax.jms.Connection |
getConnectionForProducer() |
protected abstract javax.jms.Connection |
getConnnectionForConsumer() |
javax.jms.MessageConsumer |
getConsumer() |
JmsMesageConvertor |
getJmsMessageConvertor() |
protected boolean |
isDoHandleReplyTo() |
void |
onMessage(javax.jms.Message message) |
protected javax.jms.Destination |
processReplyToDestination(javax.jms.Destination destination) |
protected abstract void |
sendMessage(javax.jms.Message message) |
void |
setConsumer(javax.jms.MessageConsumer consumer) |
protected void |
setDoHandleReplyTo(boolean doHandleReplyTo) |
void |
setJmsConnector(JmsConnector connector) |
void |
setJmsMessageConvertor(JmsMesageConvertor jmsMessageConvertor) |
void |
start() |
void |
stop() |
protected javax.jms.MessageConsumer consumer
protected AtomicBoolean started
protected JmsMesageConvertor jmsMessageConvertor
protected boolean doHandleReplyTo
protected JmsConnector jmsConnector
public DestinationBridge()
public javax.jms.MessageConsumer getConsumer()
public void setConsumer(javax.jms.MessageConsumer consumer)
consumer
- The consumer to set.public void setJmsConnector(JmsConnector connector)
connector
- public JmsMesageConvertor getJmsMessageConvertor()
public void setJmsMessageConvertor(JmsMesageConvertor jmsMessageConvertor)
jmsMessageConvertor
- protected javax.jms.Destination processReplyToDestination(javax.jms.Destination destination)
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
protected boolean isDoHandleReplyTo()
protected void setDoHandleReplyTo(boolean doHandleReplyTo)
doHandleReplyTo
- The doHandleReplyTo to set.protected abstract javax.jms.MessageConsumer createConsumer() throws javax.jms.JMSException
javax.jms.JMSException
protected abstract javax.jms.MessageProducer createProducer() throws javax.jms.JMSException
javax.jms.JMSException
protected abstract void sendMessage(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
protected abstract javax.jms.Connection getConnnectionForConsumer()
protected abstract javax.jms.Connection getConnectionForProducer()
Copyright © 2005–2016. All rights reserved.