public class MRvConsumerImpl extends MConsumerImpl implements com.tibco.tibrv.TibrvMsgCallback, com.tibco.tibrv.TibrvTimerCallback
Modifier and Type | Field and Description |
---|---|
protected int |
m_activityID |
protected MComponentRegistry |
m_componentRegistry |
protected boolean |
m_doValidate |
protected MRvEndpointSpec |
m_endpointSpec |
protected MMarshaller |
m_marshaller |
protected boolean |
m_receivedFirstEvent |
protected com.tibco.tibrv.TibrvListener |
m_rvListener |
protected com.tibco.tibrv.TibrvTimer |
m_rvTimer |
protected MRvSession |
m_session |
m_listeners, m_owner, m_tpEndpointName, m_TPlugin
Constructor and Description |
---|
MRvConsumerImpl(MSubscriberEventSource p_owner,
MRvSession p_session,
MRvEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
addAdvisoryListener(MEventListener p_listener) |
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 |
finalize() |
protected boolean |
isAdvisorySubject(java.lang.String p_subject) |
boolean |
isValidating() |
void |
noAutoConfirm() |
void |
onMsg(com.tibco.tibrv.TibrvListener p_listener,
com.tibco.tibrv.TibrvMsg p_data) |
void |
onTimer(com.tibco.tibrv.TibrvTimer p_invoker) |
protected void |
processDataEvent(java.lang.Object p_listener,
com.tibco.tibrv.TibrvMsg p_data) |
protected static void |
recordPerformanceInfo(MComponentRegistry registry,
int activityID,
com.tibco.tibrv.TibrvMsg msg) |
protected void |
stopListening() |
protected void |
stopTimer() |
void |
validateMessage(boolean doValidate) |
addListener, addTPluginName, getDestination, getListeners, getTPluginNames, hasListeners, invokeTransformationPlugin, notify, removeListener, setTPEndpointName, suspend
protected com.tibco.tibrv.TibrvListener m_rvListener
protected com.tibco.tibrv.TibrvTimer m_rvTimer
protected boolean m_doValidate
protected MRvSession m_session
protected MMarshaller m_marshaller
protected boolean m_receivedFirstEvent
protected MRvEndpointSpec m_endpointSpec
protected int m_activityID
protected MComponentRegistry m_componentRegistry
public MRvConsumerImpl(MSubscriberEventSource p_owner, MRvSession p_session, MRvEndpointSpec endpointSpec)
public void activate() throws MException
activate
in class MConsumerImpl
MException
public void deactivate() throws MException
deactivate
in class MConsumerImpl
MException
public void noAutoConfirm() throws MException
MException
public void validateMessage(boolean doValidate)
public boolean isValidating()
public void confirm(MDataEvent p_dataEvent) throws MException
MException
public void onMsg(com.tibco.tibrv.TibrvListener p_listener, com.tibco.tibrv.TibrvMsg p_data)
onMsg
in interface com.tibco.tibrv.TibrvMsgCallback
public void onTimer(com.tibco.tibrv.TibrvTimer p_invoker)
onTimer
in interface com.tibco.tibrv.TibrvTimerCallback
public void addAdvisoryListener(MEventListener p_listener)
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() throws com.tibco.tibrv.TibrvException
com.tibco.tibrv.TibrvException
protected void processDataEvent(java.lang.Object p_listener, com.tibco.tibrv.TibrvMsg p_data) throws MException
MException
protected void stopListening() throws MException
MException
protected void stopTimer() throws MException
MException
protected boolean isAdvisorySubject(java.lang.String p_subject)
protected static void recordPerformanceInfo(MComponentRegistry registry, int activityID, com.tibco.tibrv.TibrvMsg msg)
public void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable