org.msgpack.rpc.loop.netty
Class NettyEventLoop

java.lang.Object
  org.msgpack.rpc.loop.EventLoop
      org.msgpack.rpc.loop.netty.NettyEventLoop

public class NettyEventLoop
extends EventLoop

Constructor Summary

NettyEventLoop(java.util.concurrent.ExecutorService workerExecutor, java.util.concurrent.ExecutorService ioExecutor, java.util.concurrent.ScheduledExecutorService scheduledExecutor)

Method Summary

org.jboss.netty.channel.socket.ClientSocketChannelFactory	getClientFactory()
org.jboss.netty.channel.socket.ServerSocketChannelFactory	getServerFactory()
protected ServerTransport	listenTcpTransport(TcpServerConfig config, Server server)
protected ClientTransport	openTcpTransport(TcpClientConfig config, Session session)

Methods inherited from class org.msgpack.rpc.loop.EventLoop

defaultEventLoop, getIoExecutor, getScheduledExecutor, getWorkerExecutor, join, listenTransport, openTransport, setDefaultEventLoop, setFactory, shutdown, start, start, start, start

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyEventLoop

public NettyEventLoop(java.util.concurrent.ExecutorService workerExecutor,
                      java.util.concurrent.ExecutorService ioExecutor,
                      java.util.concurrent.ScheduledExecutorService scheduledExecutor)

Method Detail

getClientFactory

public org.jboss.netty.channel.socket.ClientSocketChannelFactory getClientFactory()

getServerFactory

public org.jboss.netty.channel.socket.ServerSocketChannelFactory getServerFactory()

openTcpTransport

protected ClientTransport openTcpTransport(TcpClientConfig config,
                                           Session session)

Specified by:

openTcpTransport in class EventLoop

listenTcpTransport

protected ServerTransport listenTcpTransport(TcpServerConfig config,
                                             Server server)

Specified by:

listenTcpTransport in class EventLoop