public class MJmsConsumer extends MConsumer implements TimerCallback
Modifier and Type | Field and Description |
---|---|
protected boolean |
isBusy |
protected boolean |
isRemoved |
protected int |
m_activityID |
protected MComponentRegistry |
m_componentRegistry |
protected MSubscriberEventSource |
m_owner |
protected static MJmsMarshaller |
s_marshaller |
m_consumerImpl, m_endpointSpec, m_isActivated, m_isAutoConfirm
AMX, JMS, M_FILE_SINK_ID, M_HAWK_SINK_ID, M_JMS_SINK_ID, M_RV_SINK_ID, M_SINK_ID, M_STDERR_SINK_ID, M_STDOUT_SINK_ID, M_STREAM_SINK_ID, RV
Constructor and Description |
---|
MJmsConsumer(MSubscriberEventSource owner,
MSession p_session,
MEndpointSpec endpointSpec,
boolean autoConfirm) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
deactivate() |
void |
finalize() |
java.lang.Object |
getDestination() |
MSession |
getSession() |
int |
getTransportID() |
void |
noAutoConfirm() |
void |
onMessage(javax.jms.Message p_message) |
void |
onTimer(java.lang.Object closure) |
javax.jms.Message |
receive(long timeout) |
addListener, addTPluginName, doesExplicitConfirmation, getDeliveryMode, getDestinationName, getListeners, getTimeout, getTPluginNames, hasListeners, notify, removeListener, setDestinationName, suspend
protected MSubscriberEventSource m_owner
protected MComponentRegistry m_componentRegistry
protected static MJmsMarshaller s_marshaller
protected int m_activityID
protected volatile boolean isRemoved
protected volatile boolean isBusy
public MJmsConsumer(MSubscriberEventSource owner, MSession p_session, MEndpointSpec endpointSpec, boolean autoConfirm) throws MException
MException
public void noAutoConfirm() throws MException
noAutoConfirm
in class MConsumer
MException
public void activate() throws MException
activate
in class MConsumer
MException
public void deactivate() throws MException
deactivate
in class MConsumer
MException
public int getTransportID()
getTransportID
in interface MObject
public MSession getSession()
getSession
in class MConsumer
public javax.jms.Message receive(long timeout)
public void onMessage(javax.jms.Message p_message)
public void onTimer(java.lang.Object closure)
onTimer
in interface TimerCallback
public java.lang.Object getDestination()
getDestination
in class MConsumer
public void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable