Class TLSActor

    • Constructor Detail

      • TLSActor

        public TLSActor​(int maxInputBufferSize,
                        scala.Function1<ActorSystem,​javax.net.ssl.SSLEngine> createSSLEngine,
                        scala.Function2<ActorSystem,​javax.net.ssl.SSLSession,​scala.util.Try<scala.runtime.BoxedUnit>> verifySession,
                        TLSClosing closing,
                        boolean tracing)
    • Method Detail

      • props

        public static Props props​(int maxInputBufferSize,
                                  scala.Function1<ActorSystem,​javax.net.ssl.SSLEngine> createSSLEngine,
                                  scala.Function2<ActorSystem,​javax.net.ssl.SSLSession,​scala.util.Try<scala.runtime.BoxedUnit>> verifySession,
                                  TLSClosing closing,
                                  boolean tracing)
      • props$default$5

        public static boolean props$default$5()
      • TransportIn

        public static final int TransportIn()
      • TransportOut

        public static final int TransportOut()
      • UserOut

        public static final int UserOut()
      • UserIn

        public static final int UserIn()
      • 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
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • 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)
      • akka$stream$impl$Pump$$transferState

        public static TransferState akka$stream$impl$Pump$$transferState()
      • akka$stream$impl$Pump$$transferState_$eq

        public static void akka$stream$impl$Pump$$transferState_$eq​(TransferState x$1)
      • akka$stream$impl$Pump$$currentAction

        public static scala.Function0<scala.runtime.BoxedUnit> akka$stream$impl$Pump$$currentAction()
      • akka$stream$impl$Pump$$currentAction_$eq

        public static void akka$stream$impl$Pump$$currentAction_$eq​(scala.Function0<scala.runtime.BoxedUnit> x$1)
      • initialPhase

        public static final void initialPhase​(int waitForUpstream,
                                              TransferPhase andThen)
      • waitForUpstreams

        public static final void waitForUpstreams​(int waitForUpstream)
      • gotUpstreamSubscription

        public static void gotUpstreamSubscription()
      • nextPhase

        public static final void nextPhase​(TransferPhase phase)
      • isPumpFinished

        public static final boolean isPumpFinished()
      • pump

        public static final void pump()
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • lastHandshakeStatus

        public javax.net.ssl.SSLEngineResult.HandshakeStatus lastHandshakeStatus()
      • lastHandshakeStatus_$eq

        public void lastHandshakeStatus_$eq​(javax.net.ssl.SSLEngineResult.HandshakeStatus x$1)
      • corkUser

        public boolean corkUser()
      • corkUser_$eq

        public void corkUser_$eq​(boolean x$1)
      • engine

        public javax.net.ssl.SSLEngine engine()
      • currentSession

        public javax.net.ssl.SSLSession currentSession()
      • currentSession_$eq

        public void currentSession_$eq​(javax.net.ssl.SSLSession x$1)
      • engineNeedsWrap

        public java.lang.Object engineNeedsWrap()
      • engineInboundOpen

        public java.lang.Object engineInboundOpen()
      • userHasData

        public java.lang.Object userHasData()
      • userOutCancelled

        public java.lang.Object userOutCancelled()
      • completeOrFlush

        public void completeOrFlush()
      • flushToTransport

        public void flushToTransport()
      • flushToUser

        public void flushToUser()
      • 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.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • fail

        protected void fail​(java.lang.Throwable e,
                            boolean closeTransport)
      • fail$default$2

        protected boolean fail$default$2()
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
      • pumpFailed

        protected void pumpFailed​(java.lang.Throwable e)
        Specified by:
        pumpFailed in interface Pump
      • pumpFinished

        protected void pumpFinished()
        Specified by:
        pumpFinished in interface Pump