public class MRvConsumer extends MConsumer
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
Modifier | Constructor and Description |
---|---|
protected |
MRvConsumer(MRvSession p_session,
MEndpointSpec endpointSpec) |
|
MRvConsumer(MSubscriber p_owner,
MSession p_session,
MEndpointSpec endpointSpec,
boolean autoConfirm) |
Modifier and Type | Method and Description |
---|---|
void |
addAdvisoryListener(MEventListener p_listener) |
void |
confirm(MDataEvent p_dataEvent) |
int |
getProtocol() |
MSession |
getSession() |
long |
getTimeout() |
int |
getTransportID() |
boolean |
isValidating() |
void |
noAutoConfirm() |
void |
setSubjectName(java.lang.String p_subject) |
void |
validateMessage(boolean doValidate) |
activate, addListener, addTPluginName, deactivate, doesExplicitConfirmation, getDeliveryMode, getDestination, getDestinationName, getListeners, getTPluginNames, hasListeners, notify, removeListener, setDestinationName, suspend
public MRvConsumer(MSubscriber p_owner, MSession p_session, MEndpointSpec endpointSpec, boolean autoConfirm) throws MException
MException
protected MRvConsumer(MRvSession p_session, MEndpointSpec endpointSpec) throws MException
MException
public void noAutoConfirm() throws MException
noAutoConfirm
in class MConsumer
MException
public void confirm(MDataEvent p_dataEvent) throws MException
MException
public int getProtocol()
public long getTimeout()
getTimeout
in class MConsumer
public void validateMessage(boolean doValidate)
public boolean isValidating()
public int getTransportID()
public MSession getSession()
getSession
in class MConsumer
public void setSubjectName(java.lang.String p_subject)
public void addAdvisoryListener(MEventListener p_listener)