public class MRvcmqConsumerImpl extends MRvcmConsumerImpl
m_autoConfirm, 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 |
---|
MRvcmqConsumerImpl(MSubscriberEventSource p_owner,
MRvSession p_session,
MRvEndpointSpec endpointSpec,
boolean autoConfirm) |
Modifier and Type | Method and Description |
---|---|
protected void |
createListener() |
confirm, createDataEvent, deactivate, noAutoConfirm, stopListening, stopListening, suspend
activate, addAdvisoryListener, finalize, isAdvisorySubject, isValidating, onMsg, onTimer, processDataEvent, recordPerformanceInfo, stopTimer, validateMessage
addListener, addTPluginName, getDestination, getListeners, getTPluginNames, hasListeners, invokeTransformationPlugin, notify, removeListener, setTPEndpointName
public MRvcmqConsumerImpl(MSubscriberEventSource p_owner, MRvSession p_session, MRvEndpointSpec endpointSpec, boolean autoConfirm)
protected void createListener() throws com.tibco.tibrv.TibrvException
createListener
in class MRvcmConsumerImpl
com.tibco.tibrv.TibrvException