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, org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>
public class JMSDestination
- extends AbstractMultiplexDestination
- implements org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>, 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
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
getReplyToDestination
public javax.jms.Destination getReplyToDestination(org.springframework.jms.core.JmsTemplate jmsTemplate,
Message inMessage)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
determineCorrelationID
public String determineCorrelationID(javax.jms.Message request)
throws javax.jms.JMSException
- Decides what correlationId to use for the reply by looking at the request headers. If the request has a
correlationId set this is taken. Else the messageId from the request message is used as correlation Id
- Parameters:
request
-
- Returns:
-
- Throws:
javax.jms.JMSException
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
onMessage
public void onMessage(javax.jms.Message message,
javax.jms.Session session)
- Specified by:
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>
sendExchange
public void sendExchange(Exchange exchange,
Object replyObj)
- Is called from JMSOutputStream.doClose() when the stream is fully
written. Sends the outMessage of the given exchange with the given payload
from the JMSOutputStream. If the exchange is not oneway a reply should be recieved
and set as inMessage
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