public class MInboxReceiverJmsImpl extends MJmsConsumer
Modifier and Type | Field and Description |
---|---|
protected MRpcClient |
m_rpcClient |
isBusy, isRemoved, m_activityID, m_componentRegistry, m_owner, 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 |
---|
MInboxReceiverJmsImpl(MInboxReceiver owner,
MSession session,
MEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
onMessage(javax.jms.TextMessage p_message) |
void |
setRpcClient(MRpcClient rpcClient) |
activate, deactivate, finalize, getDestination, getSession, getTransportID, noAutoConfirm, onMessage, onTimer, receive
addListener, addTPluginName, doesExplicitConfirmation, getDeliveryMode, getDestinationName, getListeners, getTimeout, getTPluginNames, hasListeners, notify, removeListener, setDestinationName, suspend
protected MRpcClient m_rpcClient
public MInboxReceiverJmsImpl(MInboxReceiver owner, MSession session, MEndpointSpec endpointSpec) throws MException
MException
public void setRpcClient(MRpcClient rpcClient)
public void onMessage(javax.jms.TextMessage p_message)