public class ReliableDeliverySupervisor
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Modifier and Type | Class and Description |
---|---|
static class |
ReliableDeliverySupervisor.AttemptSysMsgRedelivery$ |
static class |
ReliableDeliverySupervisor.GotUid |
static class |
ReliableDeliverySupervisor.GotUid$ |
static class |
ReliableDeliverySupervisor.Idle$ |
static class |
ReliableDeliverySupervisor.IsIdle$ |
static class |
ReliableDeliverySupervisor.Ungate$ |
Constructor and Description |
---|
ReliableDeliverySupervisor(scala.Option<AkkaProtocolHandle> handleOrActive,
akka.actor.Address localAddress,
akka.actor.Address remoteAddress,
scala.Option<java.lang.Object> refuseUid,
AkkaProtocolTransport transport,
RemoteSettings settings,
AkkaPduCodec codec,
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers) |
Modifier and Type | Method and Description |
---|---|
akka.actor.Cancellable |
autoResendTimer() |
scala.Option<scala.concurrent.duration.Deadline> |
bailoutAt() |
AkkaPduCodec |
codec() |
scala.Option<AkkaProtocolHandle> |
currentHandle() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
flushWait() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
gated() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
idle() |
akka.actor.Address |
localAddress() |
SeqNo |
nextSeq() |
void |
postRestart(java.lang.Throwable reason) |
void |
postStop() |
static akka.actor.Props |
props(scala.Option<AkkaProtocolHandle> handleOrActive,
akka.actor.Address localAddress,
akka.actor.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() |
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> |
receiveBuffers() |
scala.Option<java.lang.Object> |
refuseUid() |
akka.actor.Address |
remoteAddress() |
AckedSendBuffer<EndpointManager.Send> |
resendBuffer() |
void |
reset() |
long |
seqCounter() |
RemoteSettings |
settings() |
akka.actor.OneForOneStrategy |
supervisorStrategy() |
AkkaProtocolTransport |
transport() |
scala.Option<java.lang.Object> |
uid() |
boolean |
uidConfirmed() |
akka.actor.ActorRef |
writer() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ReliableDeliverySupervisor(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
public static akka.actor.Props props(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
public akka.actor.Address localAddress()
public akka.actor.Address remoteAddress()
public scala.Option<java.lang.Object> refuseUid()
public AkkaProtocolTransport transport()
public RemoteSettings settings()
public AkkaPduCodec codec()
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
public akka.actor.Cancellable autoResendTimer()
public akka.actor.OneForOneStrategy supervisorStrategy()
supervisorStrategy
in interface akka.actor.Actor
public scala.Option<AkkaProtocolHandle> currentHandle()
public AckedSendBuffer<EndpointManager.Send> resendBuffer()
public long seqCounter()
public void reset()
public SeqNo nextSeq()
public akka.actor.ActorRef writer()
public scala.Option<java.lang.Object> uid()
public scala.Option<scala.concurrent.duration.Deadline> bailoutAt()
public boolean uidConfirmed()
public void postStop()
postStop
in interface akka.actor.Actor
public void postRestart(java.lang.Throwable reason)
postRestart
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> gated()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> flushWait()