akka.remote.transport.netty
Class ClientHandler

java.lang.Object
  extended by org.jboss.netty.channel.SimpleChannelHandler
      extended by akka.remote.transport.netty.ClientHandler
All Implemented Interfaces:
CommonHandlers, NettyClientHelpers, NettyHelpers
Direct Known Subclasses:
TcpClientHandler, UdpClientHandler

public abstract class ClientHandler
extends org.jboss.netty.channel.SimpleChannelHandler
implements NettyClientHelpers, CommonHandlers

INTERNAL API


Constructor Summary
ClientHandler(NettyTransport transport, Address remoteAddress)
           
 
Method Summary
protected  void initOutbound(org.jboss.netty.channel.Channel channel, java.net.SocketAddress remoteSocketAddress, org.jboss.netty.buffer.ChannelBuffer msg)
           
 scala.concurrent.Future<AssociationHandle> statusFuture()
           
protected  scala.concurrent.Promise<AssociationHandle> statusPromise()
           
protected  NettyTransport transport()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.remote.transport.netty.NettyClientHelpers
channelConnected, channelDisconnected, channelOpen, exceptionCaught, messageReceived
 
Methods inherited from interface akka.remote.transport.netty.CommonHandlers
createHandle, init, onOpen, registerListener
 
Methods inherited from interface akka.remote.transport.netty.NettyHelpers
onConnect, onDisconnect, onException, onMessage, transformException
 

Constructor Detail

ClientHandler

public ClientHandler(NettyTransport transport,
                     Address remoteAddress)
Method Detail

transport

protected final NettyTransport transport()
Specified by:
transport in interface CommonHandlers

statusPromise

protected final scala.concurrent.Promise<AssociationHandle> statusPromise()

statusFuture

public scala.concurrent.Future<AssociationHandle> statusFuture()

initOutbound

protected final void initOutbound(org.jboss.netty.channel.Channel channel,
                                  java.net.SocketAddress remoteSocketAddress,
                                  org.jboss.netty.buffer.ChannelBuffer msg)