Package akka.stream.impl.io
Class TLSActor
- java.lang.Object
-
- akka.stream.impl.io.TLSActor
-
- All Implemented Interfaces:
Actor
,ActorLogging
,Pump
public class TLSActor extends java.lang.Object implements Actor, ActorLogging, Pump
INTERNAL API.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class 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.-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description 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 Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Scala API: Stores the context for this actor, including self, and sender.protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
TransferPhase
awaitingClose()
TransferPhase
bidirectional()
protected TransferPhase
completedPhase()
void
completeOrFlush()
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.boolean
corkUser()
void
corkUser_$eq(boolean x$1)
javax.net.ssl.SSLSession
currentSession()
void
currentSession_$eq(javax.net.ssl.SSLSession x$1)
javax.net.ssl.SSLEngine
engine()
java.lang.Object
engineInboundOpen()
java.lang.Object
engineNeedsWrap()
protected void
fail(java.lang.Throwable e, boolean closeTransport)
protected boolean
fail$default$2()
TransferPhase
flushingOutbound()
void
flushToTransport()
void
flushToUser()
TransferState
inbound()
TransferPhase
inboundClosed()
TransferState
inboundHalfClosed()
protected FanIn.InputBunch
inputBunch()
javax.net.ssl.SSLEngineResult.HandshakeStatus
lastHandshakeStatus()
void
lastHandshakeStatus_$eq(javax.net.ssl.SSLEngineResult.HandshakeStatus x$1)
TransferState
outbound()
TransferPhase
outboundClosed()
TransferState
outboundHalfClosed()
protected FanOut.OutputBunch
outputBunch()
void
postStop()
User overridable callback.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)
static boolean
props$default$5()
protected void
pumpFailed(java.lang.Throwable e)
protected void
pumpFinished()
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.ActorRef
self()
The 'self' field holds the ActorRef for this actor.void
setNewSessionParameters(TLSProtocol.NegotiateNewSession params)
static int
TransportIn()
static int
TransportOut()
java.lang.Object
userHasData()
static int
UserIn()
static int
UserOut()
java.lang.Object
userOutCancelled()
-
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, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.stream.impl.Pump
currentAction_$eq, gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, transferState_$eq, waitForUpstreams
-
-
-
-
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()
-
completedPhase
protected final TransferPhase completedPhase()
- Specified by:
completedPhase
in interfacePump
-
akka$stream$impl$Pump$_setter_$completedPhase_$eq
protected final void akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
- Specified by:
akka$stream$impl$Pump$_setter_$completedPhase_$eq
in interfacePump
-
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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
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
-
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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
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 interfaceActor
-
outputBunch
protected FanOut.OutputBunch outputBunch()
-
inputBunch
protected FanIn.InputBunch inputBunch()
-
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)
-
setNewSessionParameters
public void setNewSessionParameters(TLSProtocol.NegotiateNewSession params)
-
engineNeedsWrap
public java.lang.Object engineNeedsWrap()
-
engineInboundOpen
public java.lang.Object engineInboundOpen()
-
userHasData
public java.lang.Object userHasData()
-
userOutCancelled
public java.lang.Object userOutCancelled()
-
outbound
public TransferState outbound()
-
inbound
public TransferState inbound()
-
outboundHalfClosed
public TransferState outboundHalfClosed()
-
inboundHalfClosed
public TransferState inboundHalfClosed()
-
bidirectional
public TransferPhase bidirectional()
-
flushingOutbound
public TransferPhase flushingOutbound()
-
awaitingClose
public TransferPhase awaitingClose()
-
outboundClosed
public TransferPhase outboundClosed()
-
inboundClosed
public TransferPhase inboundClosed()
-
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.
-
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.
-
pumpFailed
protected void pumpFailed(java.lang.Throwable e)
- Specified by:
pumpFailed
in interfacePump
-
pumpFinished
protected void pumpFinished()
- Specified by:
pumpFinished
in interfacePump
-
-