Class NettyServer

java.lang.Object
org.apache.avro.ipc.netty.NettyServer
All Implemented Interfaces:
org.apache.avro.ipc.Server

public class NettyServer extends Object implements org.apache.avro.ipc.Server
A Netty-based RPC Server implementation.
  • Constructor Details

  • Method Details

    • start

      public void start()
      Specified by:
      start in interface org.apache.avro.ipc.Server
    • close

      public void close()
      Specified by:
      close in interface org.apache.avro.ipc.Server
    • getPort

      public int getPort()
      Specified by:
      getPort in interface org.apache.avro.ipc.Server
    • join

      public void join() throws InterruptedException
      Specified by:
      join in interface org.apache.avro.ipc.Server
      Throws:
      InterruptedException
    • getNumActiveConnections

      public int getNumActiveConnections()
      Returns:
      The number of clients currently connected to this server.