akka.remote
Class ReliableDeliverySupervisor

java.lang.Object
  akka.remote.ReliableDeliverySupervisor

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging

public class ReliableDeliverySupervisor
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging

INTERNAL API

Nested Class Summary

static class	ReliableDeliverySupervisor.AttemptSysMsgRedelivery$
static class	ReliableDeliverySupervisor.GotUid
static class	ReliableDeliverySupervisor.GotUid$
static class	ReliableDeliverySupervisor.Idle$
static class	ReliableDeliverySupervisor.IsIdle$
static class	ReliableDeliverySupervisor.Ungate$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Constructor Summary

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)

Method Summary

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()
double	maxResendRate()
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()
int	resendLimit()
void	reset()
long	seqCounter()
RemoteSettings	settings()
akka.actor.OneForOneStrategy	supervisorStrategy()
AkkaProtocolTransport	transport()
scala.Option<java.lang.Object>	uid()
boolean	uidConfirmed()
akka.actor.ActorRef	writer()

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

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, preRestart, preStart, self, sender, unhandled

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, log

Constructor Detail

ReliableDeliverySupervisor

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)

Method Detail

props

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)

localAddress

public akka.actor.Address localAddress()

remoteAddress

public akka.actor.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 akka.actor.Cancellable autoResendTimer()

maxResendRate

public double maxResendRate()

resendLimit

public int resendLimit()

supervisorStrategy

public akka.actor.OneForOneStrategy supervisorStrategy()

Specified by:

supervisorStrategy in interface akka.actor.Actor

currentHandle

public scala.Option<AkkaProtocolHandle> currentHandle()

resendBuffer

public AckedSendBuffer<EndpointManager.Send> resendBuffer()

seqCounter

public long seqCounter()

reset

public void reset()

nextSeq

public SeqNo nextSeq()

writer

public akka.actor.ActorRef writer()

uid

public scala.Option<java.lang.Object> uid()

bailoutAt

public scala.Option<scala.concurrent.duration.Deadline> bailoutAt()

uidConfirmed

public boolean uidConfirmed()

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

postRestart

public void postRestart(java.lang.Throwable reason)

Specified by:

postRestart in interface akka.actor.Actor

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Specified by:

receive in interface akka.actor.Actor

gated

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> gated()

idle

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()

flushWait

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> flushWait()