public class MRvcmProducerImpl extends MRvProducerImpl
m_activityID, m_aeMsgOn, m_assignMsgGUID, m_componentRegistry, m_endpointSpec, m_marshaller, m_replyDestinationName, m_session, m_sObjectName
Constructor and Description |
---|
MRvcmProducerImpl(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MRvEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
long |
getNumMessagesPublished() |
long |
getSequenceNumber() |
void |
preRegisterListener(java.lang.String cmSessionName) |
void |
send(MTree data) |
void |
setTimeout(long p_timeout) |
void |
unRegisterListener(java.lang.String cmSessionName) |
addTPluginName, assignMsgGUID, finalize, getAssignMsgGUID, getReplyDestinationName, initializeRvMsg, initializeRvTransport, isAeMsgOn, recordPerformanceInfo, sendWithReply, sendWithSyncReply, setAeMsgOn, setReplyDestinationName, unpack, validate
public MRvcmProducerImpl(MComponentRegistry registry, java.lang.String name, MSession p_session, MRvEndpointSpec endpointSpec)
public void send(MTree data) throws MException
send
in class MRvProducerImpl
MException
public long getNumMessagesPublished()
getNumMessagesPublished
in class MRvProducerImpl
public long getSequenceNumber()
public void setTimeout(long p_timeout) throws MException
MException
public void preRegisterListener(java.lang.String cmSessionName) throws MException
MException
public void unRegisterListener(java.lang.String cmSessionName) throws MException
MException