org.msgpack.rpc
Class Session

java.lang.Object
  org.msgpack.rpc.Session

Direct Known Subclasses:

Client

public class Session
extends java.lang.Object

Field Summary

protected Address	address
protected EventLoop	loop

Method Summary

org.msgpack.MessagePackObject	callApply(java.lang.String method, java.lang.Object[] args)
Future<org.msgpack.MessagePackObject>	callAsyncApply(java.lang.String method, java.lang.Object[] args)
Address	getAddress()
EventLoop	getEventLoop()
int	getRequestTimeout()
void	notifyApply(java.lang.String method, java.lang.Object[] args)
void	onResponse(int msgid, org.msgpack.MessagePackObject result, org.msgpack.MessagePackObject error)
<T> T	proxy(java.lang.Class<T> iface)
void	sendNotify(java.lang.String method, java.lang.Object[] args)
Future<org.msgpack.MessagePackObject>	sendRequest(java.lang.String method, java.lang.Object[] args)
void	setRequestTimeout(int requestTimeout)
void	transportConnectFailed()

Methods inherited from class java.lang.Object

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

Field Detail

address

protected Address address

loop

protected EventLoop loop

Method Detail

proxy

public <T> T proxy(java.lang.Class<T> iface)

getAddress

public Address getAddress()

getEventLoop

public EventLoop getEventLoop()

getRequestTimeout

public int getRequestTimeout()

setRequestTimeout

public void setRequestTimeout(int requestTimeout)

callApply

public org.msgpack.MessagePackObject callApply(java.lang.String method,
                                               java.lang.Object[] args)

callAsyncApply

public Future<org.msgpack.MessagePackObject> callAsyncApply(java.lang.String method,
                                                            java.lang.Object[] args)

notifyApply

public void notifyApply(java.lang.String method,
                        java.lang.Object[] args)

sendRequest

public Future<org.msgpack.MessagePackObject> sendRequest(java.lang.String method,
                                                         java.lang.Object[] args)

sendNotify

public void sendNotify(java.lang.String method,
                       java.lang.Object[] args)

transportConnectFailed

public void transportConnectFailed()

onResponse

public void onResponse(int msgid,
                       org.msgpack.MessagePackObject result,
                       org.msgpack.MessagePackObject error)