Package akka.remote.transport.netty
Class ClientHandler
- java.lang.Object
-
- org.jboss.netty.channel.SimpleChannelHandler
-
- akka.remote.transport.netty.ClientHandler
-
- All Implemented Interfaces:
CommonHandlers
,NettyClientHelpers
,NettyHelpers
,org.jboss.netty.channel.ChannelDownstreamHandler
,org.jboss.netty.channel.ChannelHandler
,org.jboss.netty.channel.ChannelUpstreamHandler
- Direct Known Subclasses:
TcpClientHandler
,UdpClientHandler
public abstract class ClientHandler extends org.jboss.netty.channel.SimpleChannelHandler implements NettyClientHelpers, CommonHandlers
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ClientHandler(NettyTransport transport, Address remoteAddress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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 org.jboss.netty.channel.SimpleChannelHandler
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, messageReceived, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested
-
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.CommonHandlers
createHandle, init, onOpen, registerListener
-
Methods inherited from interface akka.remote.transport.netty.NettyClientHelpers
channelConnected, channelDisconnected, channelOpen, exceptionCaught, messageReceived, super$channelConnected, super$channelDisconnected, super$channelOpen, super$messageReceived
-
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
-
initOutbound
protected final void initOutbound(org.jboss.netty.channel.Channel channel, java.net.SocketAddress remoteSocketAddress, org.jboss.netty.buffer.ChannelBuffer msg)
-
statusFuture
public scala.concurrent.Future<AssociationHandle> statusFuture()
-
statusPromise
protected final scala.concurrent.Promise<AssociationHandle> statusPromise()
-
transport
protected final NettyTransport transport()
- Specified by:
transport
in interfaceCommonHandlers
-
-