public class MAmxConsumer extends MConsumer
Modifier and Type | Field and Description |
---|---|
protected int |
m_activityID |
protected MComponentRegistry |
m_componentRegistry |
protected MSubscriberEventSource |
m_owner |
protected static MAmxMarshaller |
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 |
---|
MAmxConsumer(MSubscriberEventSource owner,
MSession p_session,
MEndpointSpec endpointSpec,
boolean autoConfirm) |
Modifier and Type | Method and Description |
---|---|
MSession |
getSession() |
int |
getTransportID() |
void |
noAutoConfirm() |
MEvent |
onMessage(AmxMessage p_message,
java.lang.String amxExchangeId,
MAmxSender amxSender) |
activate, addListener, addTPluginName, deactivate, doesExplicitConfirmation, getDeliveryMode, getDestination, getDestinationName, getListeners, getTimeout, getTPluginNames, hasListeners, notify, removeListener, setDestinationName, suspend
protected MSubscriberEventSource m_owner
protected MComponentRegistry m_componentRegistry
protected static MAmxMarshaller s_marshaller
protected int m_activityID
public MAmxConsumer(MSubscriberEventSource owner, MSession p_session, MEndpointSpec endpointSpec, boolean autoConfirm) throws MException
MException
public void noAutoConfirm() throws MException
noAutoConfirm
in class MConsumer
MException
public int getTransportID()
public MSession getSession()
getSession
in class MConsumer
public MEvent onMessage(AmxMessage p_message, java.lang.String amxExchangeId, MAmxSender amxSender)