public class JMSDestination extends AbstractMultiplexDestination implements javax.jms.MessageListener
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.
|
protected Conduit |
getInbuiltBackChannel(Message inMessage) |
JMSConfiguration |
getJmsConfig() |
protected Logger |
getLogger() |
void |
onMessage(javax.jms.Message message)
Convert JMS message received by ListenerThread to CXF message and inform incomingObserver that a
message was received.
|
protected void |
restartConnection() |
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 AbstractObservableprotected void restartConnection()
public void deactivate()
AbstractObservabledeactivate in class AbstractObservablepublic void shutdown()
AbstractDestinationshutdown in interface Destinationshutdown in class AbstractDestinationpublic void onMessage(javax.jms.Message message)
onMessage in interface javax.jms.MessageListenermessage - IOExceptionprotected Logger getLogger()
getLogger in class AbstractObservablepublic JMSConfiguration getJmsConfig()
public void setJmsConfig(JMSConfiguration jmsConfig)
Apache CXF