Package org.apache.pekko.remote.transport.netty

Interface TcpHandlers

All Superinterfaces:

CommonHandlers, NettyHelpers

public interface TcpHandlers
extends CommonHandlers

INTERNAL API

Method Summary

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 interface CommonHandlers

createHandle

AssociationHandle createHandle(io.netty.channel.Channel channel,
                               Address localAddress,
                               Address remoteAddress)

Specified by:

createHandle in interface CommonHandlers

onDisconnect

void onDisconnect(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

onDisconnect in interface NettyHelpers

onMessage

void onMessage(io.netty.channel.ChannelHandlerContext ctx,
               io.netty.buffer.ByteBuf msg)

Specified by:

onMessage in interface NettyHelpers

onException

void onException(io.netty.channel.ChannelHandlerContext ctx,
                 java.lang.Throwable e)

Specified by:

onException in interface NettyHelpers

notifyListener

void notifyListener(io.netty.channel.Channel channel,
                    AssociationHandle.HandleEvent event)