public class JMSDestination extends AbstractMultiplexDestination implements org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>, javax.jms.MessageListener
| Modifier and Type | Class and Description |
|---|---|
protected class |
JMSDestination.BackChannelConduit
Conduit for sending the reply back to the client
|
AbstractDestination.AbstractBackChannelConduitendpointInfo, referenceincomingObserver| 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, getIdgetAddress, getBackChannel, getEndpointInfogetMessageObserver, getTargetReference, getTargetReference, setMessageObserverclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetAddress, getBackChannel, getMessageObserversetMessageObserverpublic JMSDestination(Bus b, EndpointInfo info, JMSConfiguration jmsConfig)
protected Conduit getInbuiltBackChannel(Message inMessage)
getInbuiltBackChannel in class AbstractDestinationinMessage - the incoming messagepublic void activate()
activate in class AbstractObservablepublic void deactivate()
AbstractObservabledeactivate in class AbstractObservablepublic void shutdown()
AbstractDestinationshutdown in interface Destinationshutdown in class AbstractDestinationpublic javax.jms.Destination getReplyToDestination(org.springframework.jms.core.JmsTemplate jmsTemplate,
Message inMessage)
throws javax.jms.JMSException
javax.jms.JMSExceptionpublic String determineCorrelationID(javax.jms.Message request) throws javax.jms.JMSException
request - javax.jms.JMSExceptionpublic void onMessage(javax.jms.Message message)
onMessage in interface javax.jms.MessageListenermessage - IOExceptionpublic void onMessage(javax.jms.Message message,
javax.jms.Session session)
onMessage in interface org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>public void sendExchange(Exchange exchange, Object replyObj)
protected Logger getLogger()
getLogger in class AbstractObservablepublic JMSConfiguration getJmsConfig()
public void setJmsConfig(JMSConfiguration jmsConfig)
Apache CXF