public class JMSDestination extends AbstractMultiplexDestination implements org.springframework.jms.listener.SessionAwareMessageListener, javax.jms.MessageListener
Modifier and Type | Class and Description |
---|---|
protected class |
JMSDestination.BackChannelConduit
Conduit for sending the reply back to the client
|
AbstractDestination.AbstractBackChannelConduit
endpointInfo, reference
incomingObserver
Constructor and Description |
---|
JMSDestination(Bus b,
EndpointInfo info,
JMSConfiguration jmsConfig) |
Modifier and Type | Method and Description |
---|---|
void |
activate()
Initialize jmsTemplate and jmsListener from jms configuration data in jmsConfig Activate messages flow.
|
void |
deactivate()
Deactivate messages flow.
|
String |
determineCorrelationID(javax.jms.Message request)
Decides what correlationId to use for the reply by looking at the request headers.
|
protected Conduit |
getInbuiltBackChannel(Message inMessage) |
JMSConfiguration |
getJmsConfig() |
protected Logger |
getLogger() |
javax.jms.Destination |
getReplyToDestination(org.springframework.jms.core.JmsTemplate jmsTemplate,
Message inMessage) |
void |
onMessage(javax.jms.Message message)
Convert JMS message received by ListenerThread to CXF message and inform incomingObserver that a
message was received.
|
void |
onMessage(javax.jms.Message message,
javax.jms.Session session) |
void |
sendExchange(Exchange exchange,
Object replyObj)
Is called from JMSOutputStream.doClose() when the stream is fully
written.
|
void |
setJmsConfig(JMSConfiguration jmsConfig) |
void |
shutdown()
Shutdown the Destination, i.e.
|
getAddressWithId, getId
getAddress, getBackChannel, getEndpointInfo
getMessageObserver, getTargetReference, getTargetReference, setMessageObserver
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAddress, getBackChannel, getMessageObserver
setMessageObserver
public JMSDestination(Bus b, EndpointInfo info, JMSConfiguration jmsConfig)
protected Conduit getInbuiltBackChannel(Message inMessage)
getInbuiltBackChannel
in class AbstractDestination
inMessage
- the incoming messagepublic void activate()
activate
in class AbstractObservable
public void deactivate()
AbstractObservable
deactivate
in class AbstractObservable
public void shutdown()
AbstractDestination
shutdown
in interface Destination
shutdown
in class AbstractDestination
public javax.jms.Destination getReplyToDestination(org.springframework.jms.core.JmsTemplate jmsTemplate, Message inMessage) throws javax.jms.JMSException
javax.jms.JMSException
public String determineCorrelationID(javax.jms.Message request) throws javax.jms.JMSException
request
- javax.jms.JMSException
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
message
- IOException
public void onMessage(javax.jms.Message message, javax.jms.Session session)
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener
public void sendExchange(Exchange exchange, Object replyObj)
protected Logger getLogger()
getLogger
in class AbstractObservable
public JMSConfiguration getJmsConfig()
public void setJmsConfig(JMSConfiguration jmsConfig)
Apache CXF