akka.remote

Class EndpointWriter

java.lang.Object

akka.remote.EndpointActor

akka.remote.EndpointWriter

All Implemented Interfaces:

Actor, ActorLogging

public class EndpointWriter
extends EndpointActor

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EndpointWriter.AckIdleCheckTimer$
static class	EndpointWriter.BackoffTimer$
static class	EndpointWriter.FlushAndStop$
static class	EndpointWriter.Handle
static class	EndpointWriter.Handle$
static class	EndpointWriter.OutboundAck
static class	EndpointWriter.OutboundAck$
static class	EndpointWriter.StoppedReading
static class	EndpointWriter.StoppedReading$
static class	EndpointWriter.StopReading
static class	EndpointWriter.StopReading$
static class	EndpointWriter.TakeOver This message signals that the current association maintained by the local EndpointWriter and EndpointReader is to be overridden by a new inbound association.
static class	EndpointWriter.TakeOver$
static class	EndpointWriter.TookOver
static class	EndpointWriter.TookOver$

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
EndpointWriter(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.Option<ActorRef> reliableDeliverySupervisor)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.Deadline	ackDeadline()
Cancellable	ackIdleTimer()
long	adaptiveBackoffNanos()
void	adjustAdaptiveBackup()
protected static void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected 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 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)
MessageDispatcher	backoffDispatcher()
void	becomeWritingOrSendBufferedMessages()
java.util.LinkedList<java.lang.Object>	buffer()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	buffering()
static AkkaPduCodec	codec()
static ActorContext	context()
void	enqueueInBuffer(java.lang.Object msg)
static EventPublisher	eventPublisher()
ExtendedActorSystem	extendedSystem()
void	flushAndStop()
boolean	fullBackoff()
int	fullBackoffCount()
scala.Option<AkkaProtocolHandle>	handle()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	handoff()
boolean	inbound()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	initializing()
long	largeBufferLogTimestamp()
scala.Option<Ack>	lastAck()
static Address	localAddress()
static LoggingAdapter	log()
int	maxWriteCount()
DefaultMessageDispatcher	msgDispatch()
scala.concurrent.duration.Deadline	newAckDeadline()
int	noBackoffCount()
void	postRestart(java.lang.Throwable reason) User overridable callback: By default it calls preStart().
void	postStop() User overridable callback.
static void	preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
void	preStart() User overridable callback.
java.util.LinkedList<EndpointManager.Send>	prioBuffer()
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.Option<ActorRef> reliableDeliverySupervisor)
RemoteActorRefProvider	provider()
static void	publishDisassociated()
static void	publishError(java.lang.Throwable reason, Logging.LogLevel logLevel)
scala.Option<ActorRef>	reader()
scala.collection.Iterator<java.lang.Object>	readerId()
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.
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState>	receiveBuffers()
scala.Option<ActorRef>	reliableDeliverySupervisor()
static Address	remoteAddress()
RemoteMetrics	remoteMetrics()
void	scheduleBackoffTimer()
static ActorRef	self()
void	sendBufferedMessages()
static ActorRef	sender()
static RemoteSettings	settings()
int	smallBackoffCount()
AssociationHandle.DisassociateInfo	stopReason()
OneForOneStrategy	supervisorStrategy() User overridable definition the strategy to use for supervising child actors.
static Transport	transport()
void	unhandled(java.lang.Object message) User overridable callback.
int	writeCount()
boolean	writeSend(EndpointManager.Send s)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	writing()

Methods inherited from class akka.remote.EndpointActor

codec, context, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, self, settings, transport

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, sender

Methods inherited from interface akka.actor.ActorLogging

log

Constructor Detail

EndpointWriter

public EndpointWriter(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.Option<ActorRef> reliableDeliverySupervisor)

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,
                          scala.Option<ActorRef> reliableDeliverySupervisor)

sender

public static final ActorRef sender()

aroundReceive

protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                                    java.lang.Object msg)

aroundPreStart

protected static void aroundPreStart()

aroundPostStop

protected static void aroundPostStop()

aroundPreRestart

protected static void aroundPreRestart(java.lang.Throwable reason,
                                       scala.Option<java.lang.Object> message)

aroundPostRestart

protected static void aroundPostRestart(java.lang.Throwable reason)

preRestart

public static void preRestart(java.lang.Throwable reason,
                              scala.Option<java.lang.Object> message)
                       throws java.lang.Exception

Throws:

java.lang.Exception

log

public static LoggingAdapter log()

localAddress

public static Address localAddress()

remoteAddress

public static Address remoteAddress()

transport

public static Transport transport()

settings

public static RemoteSettings settings()

codec

public static AkkaPduCodec codec()

eventPublisher

public static EventPublisher eventPublisher()

publishError

public static void publishError(java.lang.Throwable reason,
                                Logging.LogLevel logLevel)

publishDisassociated

public static void publishDisassociated()

akka$actor$ActorLogging$$_log

public static LoggingAdapter akka$actor$ActorLogging$$_log()

akka$actor$ActorLogging$$_log_$eq

public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)

context

public static ActorContext context()

self

public static final ActorRef self()

akka$actor$Actor$_setter_$context_$eq

protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

receiveBuffers

public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()

reliableDeliverySupervisor

public scala.Option<ActorRef> reliableDeliverySupervisor()

extendedSystem

public ExtendedActorSystem extendedSystem()

remoteMetrics

public RemoteMetrics remoteMetrics()

backoffDispatcher

public MessageDispatcher backoffDispatcher()

reader

public scala.Option<ActorRef> reader()

handle

public scala.Option<AkkaProtocolHandle> handle()

readerId

public scala.collection.Iterator<java.lang.Object> readerId()

newAckDeadline

public scala.concurrent.duration.Deadline newAckDeadline()

ackDeadline

public scala.concurrent.duration.Deadline ackDeadline()

lastAck

public scala.Option<Ack> lastAck()

supervisorStrategy

public OneForOneStrategy supervisorStrategy()

Description copied from interface: Actor

User overridable definition the strategy to use for supervising child actors.

Returns:

(undocumented)

provider

public RemoteActorRefProvider provider()

msgDispatch

public DefaultMessageDispatcher msgDispatch()

inbound

public boolean inbound()

Specified by:

inbound in class EndpointActor

stopReason

public AssociationHandle.DisassociateInfo stopReason()

buffer

public java.util.LinkedList<java.lang.Object> buffer()

prioBuffer

public java.util.LinkedList<EndpointManager.Send> prioBuffer()

largeBufferLogTimestamp

public long largeBufferLogTimestamp()

ackIdleTimer

public Cancellable ackIdleTimer()

preStart

public void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

postRestart

public void postRestart(java.lang.Throwable reason)

Description copied from interface: Actor

User overridable callback: By default it calls preStart().

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.

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

receive

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

Description copied from interface: Actor

This defines the initial actor behavior, it must return a partial function with the actor logic.

Returns:

(undocumented)

initializing

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

enqueueInBuffer

public void enqueueInBuffer(java.lang.Object msg)

buffering

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

becomeWritingOrSendBufferedMessages

public void becomeWritingOrSendBufferedMessages()

writeCount

public int writeCount()

maxWriteCount

public int maxWriteCount()

adaptiveBackoffNanos

public long adaptiveBackoffNanos()

fullBackoff

public boolean fullBackoff()

fullBackoffCount

public int fullBackoffCount()

smallBackoffCount

public int smallBackoffCount()

noBackoffCount

public int noBackoffCount()

adjustAdaptiveBackup

public void adjustAdaptiveBackup()

sendBufferedMessages

public void sendBufferedMessages()

scheduleBackoffTimer

public void scheduleBackoffTimer()

writing

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

writeSend

public boolean writeSend(EndpointManager.Send s)

handoff

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

unhandled

public void unhandled(java.lang.Object message)

Description copied from interface: Actor

User overridable callback.

Is called when a message isn't handled by the current behavior of the actor by default it fails with either a DeathPactException (in case of an unhandled Terminated message) or publishes an UnhandledMessage to the actor's system's EventStream

Parameters:

message - (undocumented)

flushAndStop

public void flushAndStop()