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
InterruptedExceptionpublic NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr,
Consumer<io.netty.channel.socket.SocketChannel> initializer)
throws InterruptedException
InterruptedExceptionpublic NettyServer(org.apache.avro.ipc.Responder responder,
InetSocketAddress addr,
Consumer<io.netty.channel.socket.SocketChannel> initializer,
Consumer<io.netty.bootstrap.ServerBootstrap> bootStrapInitialzier)
throws InterruptedException
InterruptedExceptionpublic 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
InterruptedExceptionpublic void start()
start in interface org.apache.avro.ipc.Serverpublic void close()
close in interface org.apache.avro.ipc.Serverpublic int getPort()
getPort in interface org.apache.avro.ipc.Serverpublic void join()
throws InterruptedException
join in interface org.apache.avro.ipc.ServerInterruptedExceptionpublic int getNumActiveConnections()
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.