public class TLSActor extends java.lang.Object implements Actor, ActorLogging, Pump
Modifier and Type | Class and Description |
---|---|
class |
TLSActor.ChoppingBlock
The SSLEngine needs bite-sized chunks of data but we get arbitrary ByteString
from both the UserIn and the TransportIn ports.
|
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
TLSActor(ActorMaterializerSettings settings,
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) |
Modifier and Type | Method and Description |
---|---|
protected abstract static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected abstract 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 abstract static void |
akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1) |
static void |
akka$stream$impl$Pump$$currentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1) |
static scala.Function0<scala.runtime.BoxedUnit> |
akka$stream$impl$Pump$$currentAction() |
static void |
akka$stream$impl$Pump$$transferState_$eq(TransferState x$1) |
static TransferState |
akka$stream$impl$Pump$$transferState() |
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) |
TransferPhase |
awaitingClose() |
TransferPhase |
bidirectional() |
protected TransferPhase |
completedPhase() |
void |
completeOrFlush() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
boolean |
corkUser() |
javax.net.ssl.SSLSession |
currentSession() |
javax.net.ssl.SSLEngine |
engine() |
java.lang.Object |
engineInboundOpen() |
java.lang.Object |
engineNeedsWrap() |
protected void |
fail(java.lang.Throwable e,
boolean closeTransport) |
TransferPhase |
flushingOutbound() |
void |
flushToTransport() |
void |
flushToUser() |
static void |
gotUpstreamSubscription() |
TransferState |
inbound() |
TransferPhase |
inboundClosed() |
TransferState |
inboundHalfClosed() |
static void |
initialPhase(int waitForUpstream,
TransferPhase andThen) |
protected FanIn.InputBunch |
inputBunch() |
static boolean |
isPumpFinished() |
javax.net.ssl.SSLEngineResult.HandshakeStatus |
lastHandshakeStatus() |
static LoggingAdapter |
log() |
static void |
nextPhase(TransferPhase phase) |
TransferState |
outbound() |
TransferPhase |
outboundClosed() |
TransferState |
outboundHalfClosed() |
protected FanOut.OutputBunch |
outputBunch() |
static void |
postRestart(java.lang.Throwable reason) |
void |
postStop()
User overridable callback.
|
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
static void |
preStart() |
static Props |
props(ActorMaterializerSettings settings,
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) |
static void |
pump() |
protected void |
pumpFailed(java.lang.Throwable e) |
protected void |
pumpFinished() |
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.
|
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
static ActorRef |
sender() |
void |
setNewSessionParameters(TLSProtocol.NegotiateNewSession params) |
static SupervisorStrategy |
supervisorStrategy() |
static int |
TransportIn() |
static int |
TransportOut() |
static void |
unhandled(java.lang.Object message) |
java.lang.Object |
userHasData() |
static int |
UserIn() |
static int |
UserOut() |
java.lang.Object |
userOutCancelled() |
static void |
waitForUpstreams(int waitForUpstream) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled
log
gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, waitForUpstreams
public TLSActor(ActorMaterializerSettings settings, 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)
public static Props props(ActorMaterializerSettings settings, 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)
public static final int TransportIn()
public static final int TransportOut()
public static final int UserOut()
public static final int UserIn()
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 postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
protected abstract static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected abstract static void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static LoggingAdapter log()
public static TransferState akka$stream$impl$Pump$$transferState()
public static void akka$stream$impl$Pump$$transferState_$eq(TransferState x$1)
public static scala.Function0<scala.runtime.BoxedUnit> akka$stream$impl$Pump$$currentAction()
public static void akka$stream$impl$Pump$$currentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1)
public static final void initialPhase(int waitForUpstream, TransferPhase andThen)
public static final void waitForUpstreams(int waitForUpstream)
public static void gotUpstreamSubscription()
public static final void nextPhase(TransferPhase phase)
public static final boolean isPumpFinished()
public static final void pump()
protected abstract static void akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
protected final TransferPhase completedPhase()
completedPhase
in interface Pump
public ActorContext context()
Actor
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
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
protected FanOut.OutputBunch outputBunch()
protected FanIn.InputBunch inputBunch()
public javax.net.ssl.SSLEngine engine()
public javax.net.ssl.SSLSession currentSession()
public void setNewSessionParameters(TLSProtocol.NegotiateNewSession params)
public javax.net.ssl.SSLEngineResult.HandshakeStatus lastHandshakeStatus()
public boolean corkUser()
public java.lang.Object engineNeedsWrap()
public java.lang.Object engineInboundOpen()
public java.lang.Object userHasData()
public java.lang.Object userOutCancelled()
public TransferState outbound()
public TransferState inbound()
public TransferState outboundHalfClosed()
public TransferState inboundHalfClosed()
public TransferPhase bidirectional()
public TransferPhase flushingOutbound()
public TransferPhase awaitingClose()
public TransferPhase outboundClosed()
public TransferPhase inboundClosed()
public void completeOrFlush()
public void flushToTransport()
public void flushToUser()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
protected void fail(java.lang.Throwable e, boolean closeTransport)
public void postStop()
Actor
protected void pumpFailed(java.lang.Throwable e)
pumpFailed
in interface Pump
protected void pumpFinished()
pumpFinished
in interface Pump