org.apache.avro.ipc.netty

Class NettyServer

java.lang.Object

org.apache.avro.ipc.netty.NettyServer

All Implemented Interfaces:

Server

public class NettyServer
extends Object
implements Server

A Netty-based RPC Server implementation.

Constructor Summary

Constructors

Constructor and Description
NettyServer(Responder responder, InetSocketAddress addr)
NettyServer(Responder responder, InetSocketAddress addr, org.jboss.netty.channel.ChannelFactory channelFactory)
NettyServer(Responder responder, InetSocketAddress addr, org.jboss.netty.channel.ChannelFactory channelFactory, org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory, org.jboss.netty.handler.execution.ExecutionHandler executionHandler)
NettyServer(Responder responder, InetSocketAddress addr, org.jboss.netty.channel.ChannelFactory channelFactory, org.jboss.netty.handler.execution.ExecutionHandler executionHandler)

Method Summary

Modifier and Type	Method and Description
void	close() Stop this server.
int	getNumActiveConnections()
int	getPort() The port this server runs on.
void	join() Wait for this server to exit.
void	start() Start this server.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyServer

public NettyServer(Responder responder,
                   InetSocketAddress addr)

NettyServer

public NettyServer(Responder responder,
                   InetSocketAddress addr,
                   org.jboss.netty.channel.ChannelFactory channelFactory)

NettyServer

public NettyServer(Responder responder,
                   InetSocketAddress addr,
                   org.jboss.netty.channel.ChannelFactory channelFactory,
                   org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory,
                   org.jboss.netty.handler.execution.ExecutionHandler executionHandler)

Parameters:

executionHandler - if not null, will be inserted into the Netty pipeline. Use this when your responder does long, non-cpu bound processing (see Netty's ExecutionHandler javadoc).

pipelineFactory - Avro-related handlers will be added on top of what this factory creates

NettyServer

public NettyServer(Responder responder,
                   InetSocketAddress addr,
                   org.jboss.netty.channel.ChannelFactory channelFactory,
                   org.jboss.netty.handler.execution.ExecutionHandler executionHandler)

Parameters:

executionHandler - if not null, will be inserted into the Netty pipeline. Use this when your responder does long, non-cpu bound processing (see Netty's ExecutionHandler javadoc).

Method Detail

start

public void start()

Description copied from interface: Server

Start this server.

Specified by:

start in interface Server

close

public void close()

Description copied from interface: Server

Stop this server.

Specified by:

close in interface Server

getPort

public int getPort()

Description copied from interface: Server

The port this server runs on.

Specified by:

getPort in interface Server

join

public void join()
          throws InterruptedException

Description copied from interface: Server

Wait for this server to exit.

Specified by:

join in interface Server

Throws:

InterruptedException

getNumActiveConnections

public int getNumActiveConnections()

Returns:

The number of clients currently connected to this server.