public class MRvProducerImpl
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected int |
m_activityID |
protected boolean |
m_aeMsgOn |
protected boolean |
m_assignMsgGUID |
protected MComponentRegistry |
m_componentRegistry |
protected MRvEndpointSpec |
m_endpointSpec |
protected MMarshaller |
m_marshaller |
protected java.lang.String |
m_replyDestinationName |
protected MSession |
m_session |
protected java.lang.String |
m_sObjectName |
Constructor and Description |
---|
MRvProducerImpl(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MRvEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
assignMsgGUID(boolean assignGUID) |
void |
finalize() |
boolean |
getAssignMsgGUID() |
long |
getNumMessagesPublished() |
java.lang.String |
getReplyDestinationName() |
protected com.tibco.tibrv.TibrvMsg |
initializeRvMsg(MTree data,
java.lang.String defaultReplyDestinationName) |
protected com.tibco.tibrv.TibrvTransport |
initializeRvTransport() |
boolean |
isAeMsgOn() |
protected static void |
recordPerformanceInfo(MComponentRegistry componentRegistry,
int p_activityID,
com.tibco.tibrv.TibrvMsg msg) |
void |
send(MTree data) |
void |
sendWithReply(MTree data,
MSubscriber subscriber) |
MTree |
sendWithSyncReply(MTree data,
long timeout) |
void |
setAeMsgOn(boolean on) |
void |
setReplyDestinationName(java.lang.String replyDestinationName) |
protected MTree |
unpack(com.tibco.tibrv.TibrvMsg p_msg) |
protected com.tibco.tibrv.TibrvMsg |
validate(MTree tree) |
protected MSession m_session
protected java.lang.String m_replyDestinationName
protected MRvEndpointSpec m_endpointSpec
protected MMarshaller m_marshaller
protected MComponentRegistry m_componentRegistry
protected int m_activityID
protected java.lang.String m_sObjectName
protected boolean m_assignMsgGUID
protected boolean m_aeMsgOn
public MRvProducerImpl(MComponentRegistry registry, java.lang.String name, MSession p_session, MRvEndpointSpec endpointSpec)
public void send(MTree data) throws MException
MException
public void sendWithReply(MTree data, MSubscriber subscriber) throws MException
MException
public MTree sendWithSyncReply(MTree data, long timeout) throws MException
MException
public void setAeMsgOn(boolean on)
public boolean isAeMsgOn()
public void setReplyDestinationName(java.lang.String replyDestinationName)
public java.lang.String getReplyDestinationName()
public void assignMsgGUID(boolean assignGUID)
public boolean getAssignMsgGUID()
protected com.tibco.tibrv.TibrvMsg initializeRvMsg(MTree data, java.lang.String defaultReplyDestinationName) throws MException, com.tibco.tibrv.TibrvException
MException
com.tibco.tibrv.TibrvException
protected com.tibco.tibrv.TibrvTransport initializeRvTransport() throws MException
MException
protected com.tibco.tibrv.TibrvMsg validate(MTree tree) throws MException
MException
protected MTree unpack(com.tibco.tibrv.TibrvMsg p_msg) throws MException
MException
protected static void recordPerformanceInfo(MComponentRegistry componentRegistry, int p_activityID, com.tibco.tibrv.TibrvMsg msg)
public long getNumMessagesPublished()
public void addTPluginName(java.lang.String sTPluginName)
public void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable