akka.remote.transport.netty
Interface CommonHandlers

All Superinterfaces:

NettyHelpers

All Known Subinterfaces:

TcpHandlers, UdpHandlers

All Known Implementing Classes:

ClientHandler, ServerHandler, TcpClientHandler, TcpServerHandler, UdpClientHandler, UdpServerHandler

public interface CommonHandlers
extends NettyHelpers

INTERNAL API

Method Summary

AssociationHandle	createHandle(org.jboss.netty.channel.Channel channel, Address localAddress, Address remoteAddress)
void	init(org.jboss.netty.channel.Channel channel, java.net.SocketAddress remoteSocketAddress, Address remoteAddress, org.jboss.netty.buffer.ChannelBuffer msg, scala.Function1<AssociationHandle,java.lang.Object> op)
void	onOpen(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	registerListener(org.jboss.netty.channel.Channel channel, AssociationHandle.HandleEventListener listener, org.jboss.netty.buffer.ChannelBuffer msg, java.net.InetSocketAddress remoteSocketAddress)
NettyTransport	transport()

Methods inherited from interface akka.remote.transport.netty.NettyHelpers

onConnect, onDisconnect, onException, onMessage, transformException

Method Detail

transport

NettyTransport transport()

onOpen

void onOpen(org.jboss.netty.channel.ChannelHandlerContext ctx,
            org.jboss.netty.channel.ChannelStateEvent e)

Specified by:

onOpen in interface NettyHelpers

createHandle

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

registerListener

void registerListener(org.jboss.netty.channel.Channel channel,
                      AssociationHandle.HandleEventListener listener,
                      org.jboss.netty.buffer.ChannelBuffer msg,
                      java.net.InetSocketAddress remoteSocketAddress)

init

void init(org.jboss.netty.channel.Channel channel,
          java.net.SocketAddress remoteSocketAddress,
          Address remoteAddress,
          org.jboss.netty.buffer.ChannelBuffer msg,
          scala.Function1<AssociationHandle,java.lang.Object> op)