Package akka.remote
Class ReliableDeliverySupervisor
- java.lang.Object
-
- akka.remote.ReliableDeliverySupervisor
-
- All Implemented Interfaces:
Actor
,ActorLogging
public class ReliableDeliverySupervisor extends java.lang.Object implements Actor, ActorLogging
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReliableDeliverySupervisor.AttemptSysMsgRedelivery$
static class
ReliableDeliverySupervisor.GotUid
static class
ReliableDeliverySupervisor.GotUid$
static class
ReliableDeliverySupervisor.Idle$
static class
ReliableDeliverySupervisor.IsIdle$
static class
ReliableDeliverySupervisor.TooLongIdle$
static class
ReliableDeliverySupervisor.Ungate$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description ReliableDeliverySupervisor(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
-
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)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.Cancellable
autoResendTimer()
scala.Option<scala.concurrent.duration.Deadline>
bailoutAt()
void
bailoutAt_$eq(scala.Option<scala.concurrent.duration.Deadline> x$1)
AkkaPduCodec
codec()
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.scala.Option<AkkaProtocolHandle>
currentHandle()
void
currentHandle_$eq(scala.Option<AkkaProtocolHandle> x$1)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
flushWait()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
gated(boolean writerTerminated, boolean earlyUngateRequested)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
idle()
Address
localAddress()
scala.Option<Cancellable>
maxSilenceTimer()
void
maxSilenceTimer_$eq(scala.Option<Cancellable> x$1)
SeqNo
nextSeq()
void
postRestart(java.lang.Throwable reason)
User overridable callback: By default it callspreStart()
.void
postStop()
User overridable callback.static Props
props(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
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.java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState>
receiveBuffers()
scala.Option<java.lang.Object>
refuseUid()
Address
remoteAddress()
AckedSendBuffer<EndpointManager.Send>
resendBuffer()
void
resendBuffer_$eq(AckedSendBuffer<EndpointManager.Send> x$1)
void
reset()
ActorRef
self()
The 'self' field holds the ActorRef for this actor.long
seqCounter()
void
seqCounter_$eq(long x$1)
RemoteSettings
settings()
OneForOneStrategy
supervisorStrategy()
User overridable definition the strategy to use for supervising child actors.AkkaProtocolTransport
transport()
scala.Option<java.lang.Object>
uid()
void
uid_$eq(scala.Option<java.lang.Object> x$1)
boolean
uidConfirmed()
void
uidConfirmed_$eq(boolean x$1)
ActorRef
writer()
void
writer_$eq(ActorRef x$1)
-
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, preRestart, preStart, sender, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
-
-
-
Constructor Detail
-
ReliableDeliverySupervisor
public ReliableDeliverySupervisor(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
-
-
Method Detail
-
props
public static Props props(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
-
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)
- 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
- Parameters:
x$1
- (undocumented)
-
localAddress
public Address localAddress()
-
remoteAddress
public Address remoteAddress()
-
refuseUid
public scala.Option<java.lang.Object> refuseUid()
-
transport
public AkkaProtocolTransport transport()
-
settings
public RemoteSettings settings()
-
codec
public AkkaPduCodec codec()
-
receiveBuffers
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
-
autoResendTimer
public Cancellable autoResendTimer()
-
supervisorStrategy
public OneForOneStrategy supervisorStrategy()
Description copied from interface:Actor
User overridable definition the strategy to use for supervising child actors.- Specified by:
supervisorStrategy
in interfaceActor
- Returns:
- (undocumented)
-
currentHandle
public scala.Option<AkkaProtocolHandle> currentHandle()
-
currentHandle_$eq
public void currentHandle_$eq(scala.Option<AkkaProtocolHandle> x$1)
-
resendBuffer
public AckedSendBuffer<EndpointManager.Send> resendBuffer()
-
resendBuffer_$eq
public void resendBuffer_$eq(AckedSendBuffer<EndpointManager.Send> x$1)
-
seqCounter
public long seqCounter()
-
seqCounter_$eq
public void seqCounter_$eq(long x$1)
-
reset
public void reset()
-
nextSeq
public SeqNo nextSeq()
-
writer
public ActorRef writer()
-
writer_$eq
public void writer_$eq(ActorRef x$1)
-
uid
public scala.Option<java.lang.Object> uid()
-
uid_$eq
public void uid_$eq(scala.Option<java.lang.Object> x$1)
-
bailoutAt
public scala.Option<scala.concurrent.duration.Deadline> bailoutAt()
-
bailoutAt_$eq
public void bailoutAt_$eq(scala.Option<scala.concurrent.duration.Deadline> x$1)
-
maxSilenceTimer
public scala.Option<Cancellable> maxSilenceTimer()
-
maxSilenceTimer_$eq
public void maxSilenceTimer_$eq(scala.Option<Cancellable> x$1)
-
uidConfirmed
public boolean uidConfirmed()
-
uidConfirmed_$eq
public void uidConfirmed_$eq(boolean x$1)
-
postStop
public void postStop()
Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
-
postRestart
public void postRestart(java.lang.Throwable reason)
Description copied from interface:Actor
User overridable callback: By default it callspreStart()
.- Specified by:
postRestart
in interfaceActor
- Parameters:
reason
- the Throwable that caused the restart to happen Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
-
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.
-
gated
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> gated(boolean writerTerminated, boolean earlyUngateRequested)
-
idle
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()
-
flushWait
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> flushWait()
-
-