Class RpcHandler - deepstreamHub Java SDK RpcHandler

The entry point for RPCs, both requesting them via make(name,data) and providing them via provide(name,listener)

Methods

RpcResult make(String rpcName, Object data)

Create a remote procedure call. This requires a rpc name for routing, a JSON serializable object for any associated arguments and a callback to notify you with the rpc result or potential error.

Show example...

RpcResult result = client.rpc.make("increment", 1);

void provide(String rpcName, RpcRequestedListener rpcRequestedListener)

Registers a RpcRequestedListener as a RPC provider. If another connected client calls make(name, data) the request will be routed to the supplied listener.

Only one listener can be registered for a RPC at a time.

Please note: Deepstream tries to deliver data in its original format. Data passed to make(name, data) as a String will arrive as a String, numbers or implicitly JSON serialized objects will arrive in their respective format as well.

Show example...

client.rpc.provide("increment", new RpcRequestedListener() {
    @Override
    public void onRPCRequested(String rpcName, Object data, RpcResponse response) {
        response.send((int) data + 1);
    }
});

void unprovide(String rpcName)

Unregister a RpcRequestedListener registered via Rpc provide(name,listener)