Package akka.io
Class TcpOutgoingConnection
- java.lang.Object
-
- akka.io.TcpConnection
-
- akka.io.TcpOutgoingConnection
-
- All Implemented Interfaces:
Actor
,ActorLogging
,RequiresMessageQueue<UnboundedMessageQueueSemantics>
public class TcpOutgoingConnection extends TcpConnection
An actor handling the connection state machine for an outgoing connection to be established.INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.io.TcpConnection
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.Unregistered$, TcpConnection.UpdatePendingWriteAndThen, TcpConnection.UpdatePendingWriteAndThen$, TcpConnection.WriteFileFailed, TcpConnection.WriteFileFailed$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description TcpOutgoingConnection(TcpExt _tcp, ChannelRegistry channelRegistry, ActorRef commander, Tcp.Connect connect)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
connecting(ChannelRegistration registration, int remainingFinishConnectRetries)
static java.net.ConnectException
connectTimeoutExpired(scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
static java.net.ConnectException
FinishConnectNeverReturnedTrueException()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: 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)
-
Methods inherited from class akka.io.TcpConnection
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, channel, closeReason, closing, closingWithPendingWrite, completeConnect, connected, context, doCloseConnection, doNothing, doRead, doWrite, DroppingWriteBecauseQueueIsFullException, DroppingWriteBecauseWritingIsSuspendedException, handleClose, handleError, handleWriteMessages, peerSentEOF, PendingBufferWrite, PendingWrite, PendingWriteFile, postRestart, postStop, prepareAbort, pullMode, resumeReading, safeShutdownOutput, self, setRegistration, signDeathPact, stopWith, stopWith$default$2, suspendReading, tcp, unregistering, unsignDeathPact, waitingForRegistration, writePending
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
-
-
-
Constructor Detail
-
TcpOutgoingConnection
public TcpOutgoingConnection(TcpExt _tcp, ChannelRegistry channelRegistry, ActorRef commander, Tcp.Connect connect)
-
-
Method Detail
-
FinishConnectNeverReturnedTrueException
public static java.net.ConnectException FinishConnectNeverReturnedTrueException()
-
connectTimeoutExpired
public static java.net.ConnectException connectTimeoutExpired(scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.- Returns:
- (undocumented)
-
resolving
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> resolving(ChannelRegistration registration)
-
register
public void register(java.net.InetSocketAddress address, ChannelRegistration registration)
-
connecting
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> connecting(ChannelRegistration registration, int remainingFinishConnectRetries)
-
-