public class NettyServer extends Object implements org.apache.avro.ipc.Server
Server
implementation.Constructor and Description |
---|
NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr) |
NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr,
Consumer<io.netty.channel.socket.SocketChannel> initializer) |
NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr,
Consumer<io.netty.channel.socket.SocketChannel> initializer,
Consumer<io.netty.bootstrap.ServerBootstrap> bootStrapInitialzier) |
NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr,
Consumer<io.netty.channel.socket.SocketChannel> initializer,
Consumer<io.netty.bootstrap.ServerBootstrap> bootStrapInitialzier,
io.netty.channel.EventLoopGroup bossGroup,
io.netty.channel.EventLoopGroup workerGroup,
io.netty.channel.EventLoopGroup callerGroup) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getNumActiveConnections() |
int |
getPort() |
void |
join() |
void |
start() |
public NettyServer(org.apache.avro.ipc.Responder responder, InetSocketAddress addr) throws InterruptedException
InterruptedException
public NettyServer(org.apache.avro.ipc.Responder responder, InetSocketAddress addr, Consumer<io.netty.channel.socket.SocketChannel> initializer) throws InterruptedException
InterruptedException
public NettyServer(org.apache.avro.ipc.Responder responder, InetSocketAddress addr, Consumer<io.netty.channel.socket.SocketChannel> initializer, Consumer<io.netty.bootstrap.ServerBootstrap> bootStrapInitialzier) throws InterruptedException
InterruptedException
public NettyServer(org.apache.avro.ipc.Responder responder, InetSocketAddress addr, Consumer<io.netty.channel.socket.SocketChannel> initializer, Consumer<io.netty.bootstrap.ServerBootstrap> bootStrapInitialzier, io.netty.channel.EventLoopGroup bossGroup, io.netty.channel.EventLoopGroup workerGroup, io.netty.channel.EventLoopGroup callerGroup) throws InterruptedException
InterruptedException
public void start()
start
in interface org.apache.avro.ipc.Server
public void close()
close
in interface org.apache.avro.ipc.Server
public int getPort()
getPort
in interface org.apache.avro.ipc.Server
public void join() throws InterruptedException
join
in interface org.apache.avro.ipc.Server
InterruptedException
public int getNumActiveConnections()
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.