public class MRpcClientImpl
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected MComponentRegistry |
m_componentRegistry |
protected MEndpointSpec |
m_endpointSpec |
protected int |
m_invokeCount |
protected long |
m_numInvocations |
protected long |
m_numReplies |
protected java.lang.String |
m_objectName |
protected MSession |
m_session |
Constructor and Description |
---|
MRpcClientImpl(MComponentRegistry componentRegistry,
java.lang.String objectName,
MSession session,
MEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
asyncInvoke(MRpcClient caller,
MTree requestTree,
MEventListener eventListener,
long timeout) |
long |
getNumMessagesSent() |
void |
incrementNumReplies() |
void |
onewayInvoke(MTree tree) |
void |
preRegisterListener(java.lang.String certifiedSessionName) |
MTree |
syncInvoke(MTree request,
long timeout) |
void |
unRegisterListener(java.lang.String certifiedSessionName) |
protected long m_numInvocations
protected long m_numReplies
protected int m_invokeCount
protected MSession m_session
protected MEndpointSpec m_endpointSpec
protected MComponentRegistry m_componentRegistry
protected java.lang.String m_objectName
public MRpcClientImpl(MComponentRegistry componentRegistry, java.lang.String objectName, MSession session, MEndpointSpec endpointSpec) throws MException
MException
public void onewayInvoke(MTree tree) throws MException
MException
public MTree syncInvoke(MTree request, long timeout) throws MException
MException
public void asyncInvoke(MRpcClient caller, MTree requestTree, MEventListener eventListener, long timeout) throws MException
MException
public void preRegisterListener(java.lang.String certifiedSessionName) throws MException
MException
public void unRegisterListener(java.lang.String certifiedSessionName) throws MException
MException
public long getNumMessagesSent()
public void incrementNumReplies()
public void addTPluginName(java.lang.String sTPluginName)