org.apache.cxf.transport.jms
Class JMSDestination
java.lang.Object
org.apache.cxf.transport.AbstractObservable
org.apache.cxf.transport.AbstractDestination
org.apache.cxf.transport.AbstractMultiplexDestination
org.apache.cxf.transport.jms.JMSDestination
- All Implemented Interfaces:
- javax.jms.MessageListener, Destination, DestinationWithEndpoint, MultiplexDestination, Observable
public class JMSDestination
- extends AbstractMultiplexDestination
- implements javax.jms.MessageListener
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSDestination
public JMSDestination(Bus b,
EndpointInfo info,
JMSConfiguration jmsConfig)
getInbuiltBackChannel
protected Conduit getInbuiltBackChannel(Message inMessage)
- Specified by:
getInbuiltBackChannel in class AbstractDestination
- Parameters:
inMessage - the incoming message
- Returns:
- the inbuilt backchannel
activate
public void activate()
- Initialize jmsTemplate and jmsListener from jms configuration data in jmsConfig Activate messages flow.
- Overrides:
activate in class AbstractObservable
restartConnection
protected void restartConnection()
deactivate
public void deactivate()
- Description copied from class:
AbstractObservable
- Deactivate messages flow.
- Overrides:
deactivate in class AbstractObservable
shutdown
public void shutdown()
- Description copied from class:
AbstractDestination
- Shutdown the Destination, i.e. stop accepting incoming messages.
- Specified by:
shutdown in interface Destination- Overrides:
shutdown in class AbstractDestination
onMessage
public void onMessage(javax.jms.Message message)
- Convert JMS message received by ListenerThread to CXF message and inform incomingObserver that a
message was received. The observer will call the service and then send the response CXF message by
using the BackChannelConduit
- Specified by:
onMessage in interface javax.jms.MessageListener
- Parameters:
message -
- Throws:
IOException
getLogger
protected Logger getLogger()
- Specified by:
getLogger in class AbstractObservable
- Returns:
- the logger to use
getJmsConfig
public JMSConfiguration getJmsConfig()
setJmsConfig
public void setJmsConfig(JMSConfiguration jmsConfig)
Apache CXF