public class MRpcClient extends MEventSource
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
m_className |
protected MEndpointSpec |
m_endpointSpec |
protected MRpcClientImpl |
m_impl |
protected MSession |
m_session |
m_handlers, m_listeners
m_registry
Constructor and Description |
---|
MRpcClient(MComponentRegistry componentRegistry,
java.lang.String objectName,
MEndpointSpec endpointSpec,
java.lang.String className) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
asyncInvoke(MTree request,
MEventListener eventListener,
long timeout) |
java.lang.String |
getClassName() |
int |
getDeliveryMode() |
java.lang.String |
getDestinationName() |
long |
getNumMessagesRequested() |
MSession |
getSession() |
long |
getTimeout() |
int |
getTransportType() |
void |
incrementNumReplies() |
void |
onewayInvoke(MTree request) |
void |
preRegisterListener(java.lang.String p_certifiedSessionName) |
MTree |
syncInvoke(MTree request,
long timeout) |
void |
unRegisterListener(java.lang.String p_certifiedSessionName) |
addListener, getListeners, hasListeners, notify, removeListener
activate, deactivate, getComponentRegistry, getName, getStatus, isActivated, remove
protected MSession m_session
protected MRpcClientImpl m_impl
protected MEndpointSpec m_endpointSpec
protected java.lang.String m_className
public MRpcClient(MComponentRegistry componentRegistry, java.lang.String objectName, MEndpointSpec endpointSpec, java.lang.String className) throws MException
MException
public void onewayInvoke(MTree request) throws MException
MException
public MTree syncInvoke(MTree request, long timeout) throws MException, MInvalidInputException
MException
MInvalidInputException
public void asyncInvoke(MTree request, MEventListener eventListener, long timeout) throws MException
MException
public void preRegisterListener(java.lang.String p_certifiedSessionName) throws MException
MException
public void unRegisterListener(java.lang.String p_certifiedSessionName) throws MException
MException
public java.lang.String getClassName()
public long getTimeout()
public long getNumMessagesRequested()
public java.lang.String getDestinationName()
public int getDeliveryMode()
public MSession getSession()
public void incrementNumReplies()
public int getTransportType()
public void addTPluginName(java.lang.String sTPluginName)