public class MInboxReceiver extends MSubscriber
m_app, m_autoConfirm, m_classNames, m_consumer, m_endpointSpec, m_messageFormat, m_numMessagesReceived
m_handlers, m_listeners
m_registry
Constructor and Description |
---|
MInboxReceiver(MComponentRegistry componentRegistry,
java.lang.String objectName,
MEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
protected void |
createImpl(MComponentRegistry registry,
MEndpointSpec endpointSpec,
boolean autoConfirm) |
void |
setRpcClient(MRpcClient rpcClient) |
addAdvisoryListener, addClassName, confirm, getApp, getClassNames, getDeliveryMode, getDestination, getMRvSession, getProtocol, getSubjectName, getTimeout, init, noAutoConfirm, notify, setSubjectName, validateMessage
activate, addListener, addTPluginName, deactivate, getDestinationName, getEndpointSpec, getListeners, getMessageFormat, getNumMessagesReceived, getSession, getTPluginNames, hasListeners, incrementMessagesReceivedCount, isAutoConfirm, isValidating, removeListener, setTPEndpointName, suspend
getComponentRegistry, getName, getStatus, isActivated, remove
public MInboxReceiver(MComponentRegistry componentRegistry, java.lang.String objectName, MEndpointSpec endpointSpec) throws MException
MException
protected void createImpl(MComponentRegistry registry, MEndpointSpec endpointSpec, boolean autoConfirm) throws MException
createImpl
in class MSubscriber
MException
public void setRpcClient(MRpcClient rpcClient)