public class TcpOutgoingConnection extends TcpConnection
INTERNAL API
TcpConnection.AllRead$, TcpConnection.CloseInformation, TcpConnection.CloseInformation$, TcpConnection.ConnectionInfo, TcpConnection.ConnectionInfo$, TcpConnection.EmptyPendingWrite$, TcpConnection.EndOfStream$, TcpConnection.MoreDataWaiting$, TcpConnection.PendingBufferWrite, TcpConnection.PendingWrite, TcpConnection.PendingWriteFile, TcpConnection.ReadResult, TcpConnection.UpdatePendingWriteAndThen, TcpConnection.UpdatePendingWriteAndThen$, TcpConnection.WriteFileFailed, TcpConnection.WriteFileFailed$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
TcpOutgoingConnection(TcpExt _tcp,
ChannelRegistry channelRegistry,
ActorRef commander,
Tcp.Connect connect) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
connecting(ChannelRegistration registration,
int remainingFinishConnectRetries) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
void |
register(java.net.InetSocketAddress address,
ChannelRegistration registration) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
resolving(ChannelRegistration registration) |
abort, channel, closedMessage, closeReason, closing, closingWithPendingWrite, completeConnect, connected, doCloseConnection, doNothing, doRead, doWrite, handleClose, handleError, handleWriteMessages, peerSentEOF, PendingBufferWrite, PendingWrite, PendingWriteFile, postRestart, postStop, pullMode, resumeReading, safeShutdownOutput, signDeathPact, stopWith, suspendReading, tcp, unsignDeathPact, waitingForRegistration, writePending
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, preRestart, preStart, self, sender, supervisorStrategy, unhandled
_log, log
public TcpOutgoingConnection(TcpExt _tcp, ChannelRegistry channelRegistry, ActorRef commander, Tcp.Connect connect)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> resolving(ChannelRegistration registration)
public void register(java.net.InetSocketAddress address, ChannelRegistration registration)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> connecting(ChannelRegistration registration, int remainingFinishConnectRetries)