public class MRvcmConsumerImpl extends MRvConsumerImpl
Modifier and Type | Field and Description |
---|---|
protected boolean |
m_autoConfirm |
protected com.tibco.tibrv.TibrvCmListener |
m_cmListener |
m_activityID, m_componentRegistry, m_doValidate, m_endpointSpec, m_marshaller, m_receivedFirstEvent, m_rvListener, m_rvTimer, m_session
m_listeners, m_owner, m_tpEndpointName, m_TPlugin
Constructor and Description |
---|
MRvcmConsumerImpl(MSubscriberEventSource p_owner,
MRvSession p_session,
MRvEndpointSpec endpointSpec,
boolean autoConfirm) |
Modifier and Type | Method and Description |
---|---|
void |
confirm(MDataEvent p_dataEvent) |
protected MDataEvent |
createDataEvent(java.lang.Object p_listener,
com.tibco.tibrv.TibrvMsg p_data,
MTree p_tree,
MPublisher p_replier,
MGUID p_guid) |
protected void |
createListener() |
void |
deactivate() |
void |
noAutoConfirm() |
protected void |
stopListening() |
protected void |
stopListening(boolean cancelAgreement) |
void |
suspend() |
activate, addAdvisoryListener, finalize, isAdvisorySubject, isValidating, onMsg, onTimer, processDataEvent, recordPerformanceInfo, stopTimer, validateMessage
addListener, addTPluginName, getDestination, getListeners, getTPluginNames, hasListeners, invokeTransformationPlugin, notify, removeListener, setTPEndpointName
protected com.tibco.tibrv.TibrvCmListener m_cmListener
protected boolean m_autoConfirm
public MRvcmConsumerImpl(MSubscriberEventSource p_owner, MRvSession p_session, MRvEndpointSpec endpointSpec, boolean autoConfirm)
public void noAutoConfirm() throws MException
noAutoConfirm
in class MRvConsumerImpl
MException
public void confirm(MDataEvent p_dataEvent) throws MException
confirm
in class MRvConsumerImpl
MException
public void deactivate() throws MException
deactivate
in class MRvConsumerImpl
MException
public void suspend() throws MException
suspend
in class MConsumerImpl
MException
protected void createListener() throws com.tibco.tibrv.TibrvException
createListener
in class MRvConsumerImpl
com.tibco.tibrv.TibrvException
protected MDataEvent createDataEvent(java.lang.Object p_listener, com.tibco.tibrv.TibrvMsg p_data, MTree p_tree, MPublisher p_replier, MGUID p_guid)
createDataEvent
in class MRvConsumerImpl
protected void stopListening() throws MException
stopListening
in class MRvConsumerImpl
MException
protected void stopListening(boolean cancelAgreement) throws MException
MException