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 |
---|---|
static void |
abort() |
protected static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected static void |
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1) |
static void |
akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1) |
static LoggingAdapter |
akka$actor$ActorLogging$$_log() |
protected static void |
aroundPostRestart(java.lang.Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg) |
static java.nio.channels.SocketChannel |
channel() |
static void |
closedMessage_$eq(TcpConnection.CloseInformation x$1) |
static TcpConnection.CloseInformation |
closedMessage() |
static Tcp.ConnectionClosed |
closeReason() |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
closing(TcpConnection.ConnectionInfo info,
scala.Option<ActorRef> closeCommander) |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
closingWithPendingWrite(TcpConnection.ConnectionInfo info,
scala.Option<ActorRef> closeCommander,
Tcp.ConnectionClosed closedEvent) |
static void |
completeConnect(ChannelRegistration registration,
ActorRef commander,
scala.collection.immutable.Traversable<Inet.SocketOption> options) |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
connected(TcpConnection.ConnectionInfo info) |
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 ActorContext |
context() |
static void |
doCloseConnection(ActorRef handler,
scala.Option<ActorRef> closeCommander,
Tcp.ConnectionClosed closedEvent) |
static void |
doRead(TcpConnection.ConnectionInfo info,
scala.Option<ActorRef> closeCommander) |
static void |
doWrite(TcpConnection.ConnectionInfo info) |
static java.net.ConnectException |
FinishConnectNeverReturnedTrueException() |
static void |
handleClose(TcpConnection.ConnectionInfo info,
scala.Option<ActorRef> closeCommander,
Tcp.ConnectionClosed closedEvent) |
static void |
handleError(ActorRef handler,
java.io.IOException exception) |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
handleWriteMessages(TcpConnection.ConnectionInfo info) |
static LoggingAdapter |
log() |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
peerSentEOF(TcpConnection.ConnectionInfo info) |
static TcpConnection.PendingBufferWrite |
PendingBufferWrite(ActorRef commander,
ByteString data,
Tcp.Event ack,
Tcp.WriteCommand tail) |
static TcpConnection.PendingWrite |
PendingWrite(ActorRef commander,
Tcp.WriteCommand write) |
static TcpConnection.PendingWriteFile |
PendingWriteFile(ActorRef commander,
java.lang.String filePath,
long offset,
long count,
Tcp.Event ack,
Tcp.WriteCommand tail) |
static void |
postRestart(java.lang.Throwable reason) |
static void |
postStop() |
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
static void |
preStart() |
static boolean |
pullMode() |
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) |
static void |
resumeReading(TcpConnection.ConnectionInfo info) |
static boolean |
safeShutdownOutput() |
static ActorRef |
self() |
static ActorRef |
sender() |
static void |
signDeathPact(ActorRef actor) |
static void |
stopWith(TcpConnection.CloseInformation closeInfo) |
static SupervisorStrategy |
supervisorStrategy() |
static void |
suspendReading(TcpConnection.ConnectionInfo info) |
static TcpExt |
tcp() |
static void |
unhandled(java.lang.Object message) |
static void |
unsignDeathPact() |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitingForRegistration(ChannelRegistration registration,
ActorRef commander) |
static boolean |
writePending() |
abort, channel, closedMessage, closeReason, closing, closingWithPendingWrite, completeConnect, connected, context, doCloseConnection, doNothing, doRead, doWrite, DroppingWriteBecauseQueueIsFullException, DroppingWriteBecauseWritingIsSuspendedException, handleClose, handleError, handleWriteMessages, peerSentEOF, PendingBufferWrite, PendingWrite, PendingWriteFile, postRestart, postStop, pullMode, resumeReading, safeShutdownOutput, self, signDeathPact, stopWith, suspendReading, tcp, unsignDeathPact, waitingForRegistration, writePending
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, preRestart, preStart, sender, supervisorStrategy, unhandled
log
public TcpOutgoingConnection(TcpExt _tcp, ChannelRegistry channelRegistry, ActorRef commander, Tcp.Connect connect)
public static java.net.ConnectException FinishConnectNeverReturnedTrueException()
public static java.net.ConnectException connectTimeoutExpired(scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preStart() throws java.lang.Exception
java.lang.Exception
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
public static LoggingAdapter log()
public static TcpExt tcp()
public static java.nio.channels.SocketChannel channel()
public static boolean pullMode()
public static TcpConnection.CloseInformation closedMessage()
public static void closedMessage_$eq(TcpConnection.CloseInformation x$1)
public static void signDeathPact(ActorRef actor)
public static void unsignDeathPact()
public static boolean writePending()
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForRegistration(ChannelRegistration registration, ActorRef commander)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> connected(TcpConnection.ConnectionInfo info)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> peerSentEOF(TcpConnection.ConnectionInfo info)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> closingWithPendingWrite(TcpConnection.ConnectionInfo info, scala.Option<ActorRef> closeCommander, Tcp.ConnectionClosed closedEvent)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> closing(TcpConnection.ConnectionInfo info, scala.Option<ActorRef> closeCommander)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> handleWriteMessages(TcpConnection.ConnectionInfo info)
public static void completeConnect(ChannelRegistration registration, ActorRef commander, scala.collection.immutable.Traversable<Inet.SocketOption> options)
public static void suspendReading(TcpConnection.ConnectionInfo info)
public static void resumeReading(TcpConnection.ConnectionInfo info)
public static void doRead(TcpConnection.ConnectionInfo info, scala.Option<ActorRef> closeCommander)
public static void doWrite(TcpConnection.ConnectionInfo info)
public static Tcp.ConnectionClosed closeReason()
public static void handleClose(TcpConnection.ConnectionInfo info, scala.Option<ActorRef> closeCommander, Tcp.ConnectionClosed closedEvent)
public static void doCloseConnection(ActorRef handler, scala.Option<ActorRef> closeCommander, Tcp.ConnectionClosed closedEvent)
public static void handleError(ActorRef handler, java.io.IOException exception)
public static boolean safeShutdownOutput()
public static void abort()
public static void stopWith(TcpConnection.CloseInformation closeInfo)
public static void postStop()
public static void postRestart(java.lang.Throwable reason)
public static TcpConnection.PendingWrite PendingWrite(ActorRef commander, Tcp.WriteCommand write)
public static TcpConnection.PendingBufferWrite PendingBufferWrite(ActorRef commander, ByteString data, Tcp.Event ack, Tcp.WriteCommand tail)
public static TcpConnection.PendingWriteFile PendingWriteFile(ActorRef commander, java.lang.String filePath, long offset, long count, Tcp.Event ack, Tcp.WriteCommand tail)
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static ActorContext context()
public static final ActorRef self()
protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
receive
in class TcpConnection
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)