public class JMSDestination extends AbstractMultiplexDestination implements javax.jms.MessageListener
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.
|
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, 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
protected void restartConnection()
public void deactivate()
AbstractObservable
deactivate
in class AbstractObservable
public void shutdown()
AbstractDestination
shutdown
in interface Destination
shutdown
in class AbstractDestination
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
protected Logger getLogger()
getLogger
in class AbstractObservable
public JMSConfiguration getJmsConfig()
public void setJmsConfig(JMSConfiguration jmsConfig)
Apache CXF