public class RPCDispatcher
Intended to service transient clients only (not p2p nodes) for short-lived, transient request/response pairs. If you need robustness, this is the wrong system. If you don't want a response, this is probably the wrong system (you could just send a message). If you want complex customisation of how requests/responses are handled, this is probably the wrong system.
Constructor and Description |
---|
RPCDispatcher(RPCOps ops,
RPCUserService userService,
java.lang.String nodeLegalName)
Intended to service transient clients only (not p2p nodes) for short-lived, transient request/response pairs.
If you need robustness, this is the wrong system. If you don't want a response, this is probably the
wrong system (you could just send a message). If you want complex customisation of how requests/responses
are handled, this is probably the wrong system.
|
Modifier and Type | Method and Description |
---|---|
void |
dispatch(ClientRPCRequestMessage msg) |
java.lang.String |
getNodeLegalName() |
RPCOps |
getOps() |
User |
getUser(org.apache.activemq.artemis.api.core.client.ClientMessage message) |
RPCUserService |
getUserService() |
void |
send(SerializedBytes<?> data,
java.lang.String toAddress) |
void |
start(org.apache.activemq.artemis.api.core.client.ClientConsumer rpcConsumer,
org.apache.activemq.artemis.api.core.client.ClientConsumer rpcNotificationConsumer,
AffinityExecutor onExecutor) |
public RPCDispatcher(RPCOps ops, RPCUserService userService, java.lang.String nodeLegalName)
Intended to service transient clients only (not p2p nodes) for short-lived, transient request/response pairs. If you need robustness, this is the wrong system. If you don't want a response, this is probably the wrong system (you could just send a message). If you want complex customisation of how requests/responses are handled, this is probably the wrong system.
public void dispatch(ClientRPCRequestMessage msg)
public void send(SerializedBytes<?> data, java.lang.String toAddress)
public void start(org.apache.activemq.artemis.api.core.client.ClientConsumer rpcConsumer, org.apache.activemq.artemis.api.core.client.ClientConsumer rpcNotificationConsumer, AffinityExecutor onExecutor)
public User getUser(org.apache.activemq.artemis.api.core.client.ClientMessage message)
public RPCOps getOps()
public RPCUserService getUserService()
public java.lang.String getNodeLegalName()