Interface TcpHandlers
-
- All Superinterfaces:
CommonHandlers
,NettyHelpers
public interface TcpHandlers extends CommonHandlers
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description AssociationHandle
createHandle(io.netty.channel.Channel channel, Address localAddress, Address remoteAddress)
LoggingAdapter
log()
void
notifyListener(io.netty.channel.Channel channel, AssociationHandle.HandleEvent event)
void
onDisconnect(io.netty.channel.ChannelHandlerContext ctx)
void
onException(io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable e)
void
onMessage(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf msg)
void
registerListener(io.netty.channel.Channel channel, AssociationHandle.HandleEventListener listener, java.net.InetSocketAddress remoteSocketAddress)
-
Methods inherited from interface org.apache.pekko.remote.transport.netty.CommonHandlers
init, onOpen, transport
-
Methods inherited from interface org.apache.pekko.remote.transport.netty.NettyHelpers
onConnect, transformException
-
-
-
-
Method Detail
-
log
LoggingAdapter log()
-
registerListener
void registerListener(io.netty.channel.Channel channel, AssociationHandle.HandleEventListener listener, java.net.InetSocketAddress remoteSocketAddress)
- Specified by:
registerListener
in interfaceCommonHandlers
-
createHandle
AssociationHandle createHandle(io.netty.channel.Channel channel, Address localAddress, Address remoteAddress)
- Specified by:
createHandle
in interfaceCommonHandlers
-
onDisconnect
void onDisconnect(io.netty.channel.ChannelHandlerContext ctx)
- Specified by:
onDisconnect
in interfaceNettyHelpers
-
onMessage
void onMessage(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf msg)
- Specified by:
onMessage
in interfaceNettyHelpers
-
onException
void onException(io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable e)
- Specified by:
onException
in interfaceNettyHelpers
-
notifyListener
void notifyListener(io.netty.channel.Channel channel, AssociationHandle.HandleEvent event)
-
-