org.msgpack.rpc
Class Server

java.lang.Object
  org.msgpack.rpc.SessionPool
      org.msgpack.rpc.Server

All Implemented Interfaces:

java.io.Closeable

public class Server
extends SessionPool

Constructor Summary

Server()

Server(ClientConfig config)

Server(ClientConfig config, EventLoop loop)

Server(EventLoop loop)

Method Summary

void	close()
void	listen(java.net.InetSocketAddress address)
void	listen(int port)
void	listen(ServerConfig config)
void	listen(java.lang.String host, int port)
void	onNotify(java.lang.String method, org.msgpack.MessagePackObject args)
void	onRequest(MessageSendable channel, int msgid, java.lang.String method, org.msgpack.MessagePackObject args)
void	serve(Dispatcher dp)
void	serve(java.lang.Object handler)

Methods inherited from class org.msgpack.rpc.SessionPool

getEventLoop, getSession, getSession

Methods inherited from class java.lang.Object

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

Constructor Detail

Server

public Server()

Server

public Server(ClientConfig config)

Server

public Server(EventLoop loop)

Server

public Server(ClientConfig config,
              EventLoop loop)

Method Detail

serve

public void serve(Dispatcher dp)

serve

public void serve(java.lang.Object handler)

listen

public void listen(java.lang.String host,
                   int port)
            throws java.net.UnknownHostException,
                   java.io.IOException

Throws:

java.net.UnknownHostException

java.io.IOException

listen

public void listen(java.net.InetSocketAddress address)
            throws java.io.IOException

Throws:

java.io.IOException

listen

public void listen(int port)
            throws java.io.IOException

Throws:

java.io.IOException

listen

public void listen(ServerConfig config)
            throws java.io.IOException

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface java.io.Closeable

Overrides:

close in class SessionPool

onRequest

public void onRequest(MessageSendable channel,
                      int msgid,
                      java.lang.String method,
                      org.msgpack.MessagePackObject args)

onNotify

public void onNotify(java.lang.String method,
                     org.msgpack.MessagePackObject args)