Package akka.io

Class TcpOutgoingConnection

    • Method Detail

      • FinishConnectNeverReturnedTrueException

        public static java.net.ConnectException FinishConnectNeverReturnedTrueException()
      • connectTimeoutExpired

        public static java.net.ConnectException connectTimeoutExpired​(scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
      • sender

        public static final ActorRef sender()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • tcp

        public static TcpExt tcp()
      • channel

        public static java.nio.channels.SocketChannel channel()
      • pullMode

        public static boolean pullMode()
      • signDeathPact

        public static void signDeathPact​(ActorRef actor)
      • unsignDeathPact

        public static void unsignDeathPact()
      • writePending

        public static boolean writePending()
      • waitingForRegistration

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> waitingForRegistration​(ChannelRegistration registration,
                                                                                                                   ActorRef commander)
      • connected

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> connected​(TcpConnection.ConnectionInfo info)
      • peerSentEOF

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> peerSentEOF​(TcpConnection.ConnectionInfo info)
      • handleWriteMessages

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> handleWriteMessages​(TcpConnection.ConnectionInfo info)
      • unregistering

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> unregistering()
      • handleError

        public static void handleError​(ActorRef handler,
                                       java.io.IOException exception)
      • safeShutdownOutput

        public static boolean safeShutdownOutput()
      • prepareAbort

        public static void prepareAbort()
      • stopWith$default$2

        public static boolean stopWith$default$2()
      • postStop

        public static void postStop()
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • self

        public static final ActorRef self()
      • akka$actor$Actor$_setter_$context_$eq

        protected static void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
      • akka$actor$Actor$_setter_$self_$eq

        protected static final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Specified by:
        receive in class TcpConnection
      • 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)