Package 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 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 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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.duration.Deadline
ackDeadline()
void
ackDeadline_$eq(scala.concurrent.duration.Deadline x$1)
Cancellable
ackIdleTimer()
long
adaptiveBackoffNanos()
void
adaptiveBackoffNanos_$eq(long x$1)
void
adjustAdaptiveBackup()
MessageDispatcher
backoffDispatcher()
void
becomeWritingOrSendBufferedMessages()
java.util.LinkedList<java.lang.Object>
buffer()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
buffering()
void
enqueueInBuffer(java.lang.Object msg)
ExtendedActorSystem
extendedSystem()
void
flushAndStop()
boolean
fullBackoff()
void
fullBackoff_$eq(boolean x$1)
int
fullBackoffCount()
void
fullBackoffCount_$eq(int x$1)
scala.Option<AkkaProtocolHandle>
handle()
void
handle_$eq(scala.Option<AkkaProtocolHandle> x$1)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
handoff()
boolean
inbound()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
initializing()
long
largeBufferLogTimestamp()
void
largeBufferLogTimestamp_$eq(long x$1)
scala.Option<Ack>
lastAck()
void
lastAck_$eq(scala.Option<Ack> x$1)
int
maxWriteCount()
void
maxWriteCount_$eq(int x$1)
DefaultMessageDispatcher
msgDispatch()
scala.concurrent.duration.Deadline
newAckDeadline()
int
noBackoffCount()
void
noBackoffCount_$eq(int x$1)
void
postRestart(java.lang.Throwable reason)
User overridable callback: By default it callspreStart()
.void
postStop()
User overridable callback.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()
scala.Option<ActorRef>
reader()
void
reader_$eq(scala.Option<ActorRef> x$1)
scala.collection.Iterator<java.lang.Object>
readerId()
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<ActorRef>
reliableDeliverySupervisor()
RemoteMetrics
remoteMetrics()
void
scheduleBackoffTimer()
void
sendBufferedMessages()
int
smallBackoffCount()
void
smallBackoffCount_$eq(int x$1)
AssociationHandle.DisassociateInfo
stopReason()
void
stopReason_$eq(AssociationHandle.DisassociateInfo x$1)
OneForOneStrategy
supervisorStrategy()
User overridable definition the strategy to use for supervising child actors.void
unhandled(java.lang.Object message)
User overridable callback.int
writeCount()
void
writeCount_$eq(int x$1)
boolean
writeSend(EndpointManager.Send s)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
writing()
-
Methods inherited from class akka.remote.EndpointActor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, 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_$eq, 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)
-
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()
-
reader_$eq
public void reader_$eq(scala.Option<ActorRef> x$1)
-
handle
public scala.Option<AkkaProtocolHandle> handle()
-
handle_$eq
public void handle_$eq(scala.Option<AkkaProtocolHandle> x$1)
-
readerId
public scala.collection.Iterator<java.lang.Object> readerId()
-
newAckDeadline
public scala.concurrent.duration.Deadline newAckDeadline()
-
ackDeadline
public scala.concurrent.duration.Deadline ackDeadline()
-
ackDeadline_$eq
public void ackDeadline_$eq(scala.concurrent.duration.Deadline x$1)
-
lastAck
public scala.Option<Ack> lastAck()
-
lastAck_$eq
public void lastAck_$eq(scala.Option<Ack> x$1)
-
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 classEndpointActor
-
stopReason
public AssociationHandle.DisassociateInfo stopReason()
-
stopReason_$eq
public void stopReason_$eq(AssociationHandle.DisassociateInfo x$1)
-
buffer
public java.util.LinkedList<java.lang.Object> buffer()
-
prioBuffer
public java.util.LinkedList<EndpointManager.Send> prioBuffer()
-
largeBufferLogTimestamp
public long largeBufferLogTimestamp()
-
largeBufferLogTimestamp_$eq
public void largeBufferLogTimestamp_$eq(long x$1)
-
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 callspreStart()
.- 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
Scala API: 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()
-
writeCount_$eq
public void writeCount_$eq(int x$1)
-
maxWriteCount
public int maxWriteCount()
-
maxWriteCount_$eq
public void maxWriteCount_$eq(int x$1)
-
adaptiveBackoffNanos
public long adaptiveBackoffNanos()
-
adaptiveBackoffNanos_$eq
public void adaptiveBackoffNanos_$eq(long x$1)
-
fullBackoff
public boolean fullBackoff()
-
fullBackoff_$eq
public void fullBackoff_$eq(boolean x$1)
-
fullBackoffCount
public int fullBackoffCount()
-
fullBackoffCount_$eq
public void fullBackoffCount_$eq(int x$1)
-
smallBackoffCount
public int smallBackoffCount()
-
smallBackoffCount_$eq
public void smallBackoffCount_$eq(int x$1)
-
noBackoffCount
public int noBackoffCount()
-
noBackoffCount_$eq
public void noBackoffCount_$eq(int x$1)
-
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 aDeathPactException
(in case of an unhandledTerminated
message) or publishes anUnhandledMessage
to the actor's system'sEventStream
- Parameters:
message
- (undocumented)
-
flushAndStop
public void flushAndStop()
-
-