rpcfy

Class JsonRPCMessageHandler

java.lang.Object

rpcfy.JsonRPCMessageHandler

All Implemented Interfaces:

MessageReceiver<java.lang.String>

public final class JsonRPCMessageHandler
extends java.lang.Object
implements MessageReceiver<java.lang.String>

Takes care of sending the JSONRPC messages using the provided MessageSender, and handles the incoming JSON RPC messages when delivered to onMessage(String).

See Also:

RPCfy

Constructor Summary

Constructors

Constructor and Description
JsonRPCMessageHandler(MessageSender<java.lang.String> messageSender) Creates an instance of JsonRPCMessageHandler.

Method Summary

Modifier and Type	Method and Description
void	addMethodDelegate(RPCMethodDelegate methodDelegate) Adds a delegate for a given method in a interface.
static <T> T	asException(java.lang.String exceptionName, java.lang.String exceptionMessage, java.lang.Class<T> exception) Internal use to convert exception
void	clear() Clears all the stubs registered with this.
void	clearStub(java.lang.Object object) Clears any stub created for the given instance
void	clearStub(RPCStub stub) Clears any previously registered RPCStub
java.util.Map<java.lang.String,java.lang.String>	getExtras() Return any extras set
java.lang.Object	getMethodDelegate(RPCMethodDelegate delegate) Returns any method delegate set for the given method
RPCStub	getStub(java.lang.Object object) Returns any stub assosiated with given object
void	onMessage(java.lang.String message) Called to processes given message
void	registerStub(RPCStub stub) Register a RPCStub with this handler, so that any message intended for the stub can be delivered.
void	sendMessage(java.lang.String message) Used internally by generated Proxy/Stub to send the message using the MessageSender associated with this
java.lang.String	sendMessageAndWaitForResponse(java.lang.String message, java.lang.String interfaceName, int methodID, int rpcID) Used internally by generated Proxy/Stub to send the message using the MessageSender associated with this
void	setExtra(java.util.Map<java.lang.String,java.lang.String> requestExtras) Put any extra json key/value to be send with the request message.
void	setLogEnabled(boolean logEnabled) Enable/disable debug loging
void	setRequestTimeout(long requestTimeout) Sets the request timeout for blocking requests.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonRPCMessageHandler

public JsonRPCMessageHandler(MessageSender<java.lang.String> messageSender)

Creates an instance of JsonRPCMessageHandler.

Use a single instance for client side, and another single instance at server side.

Parameters:

messageSender - The generated messages will be send using this.

Method Detail

setLogEnabled

public void setLogEnabled(boolean logEnabled)

Enable/disable debug loging

setExtra

public void setExtra(java.util.Map<java.lang.String,java.lang.String> requestExtras)

Put any extra json key/value to be send with the request message.

Any key starting with custom_ will also be relayed back in the response

addMethodDelegate

public void addMethodDelegate(RPCMethodDelegate methodDelegate)

Adds a delegate for a given method in a interface. If this is added to the proxy side, the method will be called on the given instance without proxying to stub. If this is added to the stub side, the method will be called on the given instance instead of the implementation that the stub is wrapping

getMethodDelegate

public java.lang.Object getMethodDelegate(RPCMethodDelegate delegate)

Returns any method delegate set for the given method

getExtras

public java.util.Map<java.lang.String,java.lang.String> getExtras()

Return any extras set

onMessage

public void onMessage(java.lang.String message)

Description copied from interface: MessageReceiver

Called to processes given message

Specified by:

onMessage in interface MessageReceiver<java.lang.String>

sendMessage

public void sendMessage(java.lang.String message)

Used internally by generated Proxy/Stub to send the message using the MessageSender associated with this

sendMessageAndWaitForResponse

public java.lang.String sendMessageAndWaitForResponse(java.lang.String message,
                                                      java.lang.String interfaceName,
                                                      int methodID,
                                                      int rpcID)

Used internally by generated Proxy/Stub to send the message using the MessageSender associated with this

registerStub

public void registerStub(RPCStub stub)

Register a RPCStub with this handler, so that any message intended for the stub can be delivered.

clearStub

public void clearStub(RPCStub stub)

Clears any previously registered RPCStub

See Also:

registerStub(RPCStub)

clear

public void clear()

Clears all the stubs registered with this.

clearStub

public void clearStub(java.lang.Object object)

Clears any stub created for the given instance

Parameters:

object -

getStub

public RPCStub getStub(java.lang.Object object)

Returns any stub assosiated with given object

setRequestTimeout

public void setRequestTimeout(long requestTimeout)

Sets the request timeout for blocking requests. Default timeout is 2 minutes

asException

public static <T> T asException(java.lang.String exceptionName,
                                java.lang.String exceptionMessage,
                                java.lang.Class<T> exception)

Internal use to convert exception