|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
AbstractPipePair
which has the same types
for commands and events.IOManager
to accept an incoming
connection to the ServerSocketChannel associated with this
IO.Handle
.
Actor
.
Actor
.
Actor
.
Actor
.
IOManagerActor
that performs the actual
IO.
Props
to determine the type of actor which will
be created.
ActorClassification
An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef
Means that ActorRefs "listen" to other ActorRefs
E is the Event typeActorSystem
.
".."
signifies the parent of an actor.
".."
signifies the parent of an actor.
Identify
.Kill
messageActorSelection.resolveOne(akka.util.Timeout)
can't identify the actor the
Future
is completed with this failure.ActorSystem
.org.apache.camel.model.ProcessorDefinition
.ActorSelection
from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
ActorSelection
from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
ActorSystem
Returns a default value of bundle--ActorSystem
is no name is being specified
Address
ordering type class, sorts addresses by host and port.
Address
ordering type class, sorts addresses by host and port.
Int
.Affinity
option shall set the I/O thread affinity for newly created connections on the specified socket.Affinity
valueFuture
that will be completed with the success or failure of the provided value
after the specified duration.
Future
that will be completed with the success or failure of the provided Callable
after the specified duration.
Future
that will be completed with the success or failure of the provided value
after the specified duration.
Future
that will be completed with the success or failure of the provided Callable
after the specified duration.
Future
that will be completed with the success or failure of the provided value
after the specified duration.
Directive
(Resume, Restart, Stop) specified in the Decider
to all children when one fails, as opposed to OneForOneStrategy
that applies
it only to the child actor that failed.WriteCommand
to form a CompoundWrite
.
IO.Done
IO.Iteratee
.
IO.Input
, returning the resulting
Iteratee and the remaining Input.
LogSource
, generate the
string representation and originating class.
LogSource
and
ActorSystem
, generate the string representation and
originating class.
LogSource
, generate the
string representation and originating class.
LogSource
and
ActorSystem
, generate the string representation and
originating class.
Tcp
or Udp
.
Tcp
or Udp
.
PipePair
from the two given functions; useful for not capturing $outer
references.
PipePair
from the two given functions; useful for not capturing $outer
references.
WriteCommand
.
?
and ask
methods on
ActorRef
, which will defer to the
ask(actorRef, message)(timeout)
method defined here.
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
?
and ask
methods on
ActorSelection
, which will defer to the
ask(actorSelection, message)(timeout)
method defined here.
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender
reference provided.
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender
reference provided.
TestTransport.SwitchableLoggedBehavior
for the associate() method.
Transport
.ActorRef
instances to a HandleEventListener.AssociationHandle
might receive.AssociationHandle
to listen to association events.akka.remote.transport.AssociationHandle.readHandlerPromise
) when an inbound payload arrives.IO.IterateeRefAsync
containing an initial
IO.Iteratee
.
IO.IterateeRefAsync
.
IO.IterateeRefAsync
for each new key.
java.lang.Runnable
.
java.util.concurrent.Callable
.
true
or the timeout
expires, whichever comes first.
true
or the timeout
expires, whichever comes first.
true
or the timeout
expires, whichever comes first.
.await()
onto all Awaitables, using remaining duration from the innermost
enclosing within
block or QueryTimeout.
Backlog
option shall set the maximum length of the queue of outstanding peer connections
for the specified socket; this only applies to connection-oriented transports.backoffThreshold
and backoffRate
BackpressureBuffer.HighWatermarkReached
) and when
it subsequently empties (BackpressureBuffer.LowWatermarkReached
).BalancingDispatcher
.TcpExt.getManager()
in order to bind to a listening socket.
TcpExt.getManager()
in order to bind to a listening socket.
UdpExt.manager()
in order to bind to the given
local port (or an automatically assigned one if the port number is zero).
UdpExt.manager()
in order to bind to the given
local port (or an automatically assigned one if the port number is zero).
T
.
Inet.SocketOption
to set the SO_BROADCAST option
Inet.SocketOption
to set the SO_BROADCAST option
LoggingAdapter
that publishes Logging.LogEvent
to event stream.ByteString
.CircuitBreaker.withCircuitBreaker(scala.Function0>)
CircuitBreaker.withSyncCircuitBreaker(scala.Function0)
TimerTask
associated with this handle.
IOManager
to close the Channel
associated with this IO.Handle
.
ClusterClient
connects to this actor to retrieve.ClusterReceptionist
and accompanying DistributedPubSubMediator
with settings defined in config section akka.contrib.cluster.receptionist
.RouterConfig
implementation for deployment on cluster nodes.totalInstances
of cluster router must be > 0
maxInstancesPerNode
of cluster router must be > 0
maxInstancesPerNode
of cluster router must be 1 when routeesPath is definedDeploy
with FSM
type parameterswith FSM
type parametersTcpPipelineHandler
actor.
Controller
’s port to which all
Player
s connect, it issues commands to their
akka.remote.testconductor.NetworkFailureInjector
and provides support
for barriers using the BarrierCoordinator
.TcpExt.getManager()
.
remoteAddress
with an optional localAddress
to bind to given the specified Socket Options
remoteAddress
without binding to a local address.
remoteAddress
without binding to a local address and without
specifying options.
remoteAddress
with a connection timeout
without binding to a local address and without
specifying options.
TcpExt.getManager()
.
remoteAddress
with an optional localAddress
to bind to given the specified Socket Options
remoteAddress
without binding to a local address.
remoteAddress
without binding to a local address and without
specifying options.
remoteAddress
with a connection timeout
without binding to a local address and without
specifying options.
UdpExt.manager()
in order to bind to a local
port (optionally with the chosen localAddress
) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress
.
localAddress
.
localAddress
or options
.
UdpExt.manager()
in order to bind to a local
port (optionally with the chosen localAddress
) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress
.
localAddress
.
localAddress
or options
.
hashMapping
when
constructing the ConsistentHashingRouter
the messages need to implement this interface to define what
data to use for the consistent hash key.hashMapping
when
constructing the ConsistentHashingRouter
and messages can't implement ConsistentHashingRouter.ConsistentHashable
themselves they can we wrapped by this envelope instead.Coordinated
is a message wrapper that adds a CommitBarrier
for explicitly
coordinating transactions across actors or threads.watch
.Creator
.
Creator
.
Props
from the handOverData
sent from
previous singleton.
PipePair
from the given AbstractPipePair
.
PipePair
from the given AbstractSymmetricPipePair
.
PipePair
from the given AbstractPipePair
.
PipePair
from the given AbstractSymmetricPipePair
.
WriteCommand
.
ActorSystem
, using the name specified
ActorSystem
, using the name specified.
Class[_]
object and a constructor description
will create a new instance of that class.
args
argument.
RouteeProvider
responsible for creating or
looking up routees.
Props
and registers them.
Actor
with Stash
,
since just using actor()(new Act with Stash{})
will not be able to see the
Stash component due to type erasure.source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Debug events, the most efficient is to use Left("")
.Decider
is used by default in the supervisor strategy.
Decider
is used by default in the supervisor strategy.
FailureDetectorRegistry
.ClusterClient
Props
with
default values.
ClusterClient
Props
with
default values.
ClusterSingletonManager
Props
with default values.
ClusterSingletonManager
Props
with default values.
DistributedPubSubMediator
Props
with default values.
DistributedPubSubMediator
Props
with default values.
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem
.
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem
.
TestTransport.SwitchableLoggedBehavior
for the disassociate() method on handles.
UdpConnected.Connected
message) in order to close the socket.
UdpConnected.Connected
message) in order to close the socket.
Deploy
instance.
Dispatcher
binds a set of Actors to a thread pool backed up by a
BlockingQueue
.Dispatcher
.DistributedPubSubMediator
actor
with settings defined in config section akka.contrib.cluster.pub-sub
.Logging.LogEvent
when the string representation was supplied
directly.ReflectiveDynamicAccess
is the default implementation).throwable
applies an upper bound on the type of exception contained in the Error event
source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either
with String.startsWith or Regex.findFirstIn().isDefined); if the message
itself does not match, the match is retried with the contained Exception’s
message; if both are null
, the filter always matches if at
the same time the Exception’s stack trace is empty (this catches
JVM-omitted “fast-throw” exceptions)
If you want to match all Error events, the most efficient is to use Left("")
.TcpPipelineHandler
actor.
expectMsg(remaining, obj)
, but correctly treating the timeFactor.
expectMsgAllClassOf(remaining, obj...)
, but correctly treating the timeFactor.
expectMsgAllConformingOf(remaining, obj...)
, but correctly treating the timeFactor.
expectMsgAllOf(remaining(), obj...)
, but correctly
treating the timeFactor.
expectMsgAllOf(remaining, obj...)
, but correctly treating the timeFactor.
expectMsgAnyClassOf(remaining(), obj...)
, but
correctly treating the timeFactor.
expectMsgAnyClassOf(remaining, obj...)
, but correctly treating the timeFactor.
expectMsgAnyOf(remaining(), obj...)
, but correctly
treating the timeFactor.
expectMsgAnyOf(remaining, obj...)
, but correctly treating the timeFactor.
expectMsgClass(remaining(), clazz)
, but correctly
treating the timeFactor.
expectMsgClass(remaining, c)
, but correctly treating the timeFactor.
expectMsgEquals(remaining(), obj)
, but correctly
treating the timeFactor.
expectMsgType[T](remaining)
, but correctly treating the timeFactor.
expectNoMsg(remaining())
, but correctly treating the
timeFactor.
expectNoMsg(remaining)
, but correctly treating the timeFactor.
expectTerminated(remaining(), target)
,
but correctly treating the timeFactor.
Extension
).Route
out of a RoutedActorRef.Route
out of a RoutedActorRef.Class
’s simple name.
Class
’s simple name.
Class
’s simple name.
Class
’s simple name.
FSM.SubscribeTransitionCallBack
before sending any
FSM.Transition
messages.FSM
will be wrapped inside an
Event
, which allows pattern matching to extract both state and data.FSM
is shutting itself down because of
an error, e.g.LoggingFSM
, can be obtained by calling getLog
.stop()
.whenUnhandled
and onTermination
handlers.FSM
is shutting down.system.stop(fsm)
from outside;
also applies to Stop
supervision directive.FSM
: the state
name, the state data, possibly custom timeout, stop reason and replies
accumulated while processing the last message.FSM
whithin the
onTermination
block.FSM
to request first the FSM.CurrentState
and then a series of FSM.Transition
updates.FSM.SubscribeTransitionCallBack
).FSM.Transition
notifications which was
effected by sending the corresponding FSM.SubscribeTransitionCallBack
.Future
object with the result of that computation.
Future
object with the result of that computation.
akka.actor.IO.EOF
to this Iteratee and returns the
result if available.
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
ActorSystem
instance.
ActorSystem
name will be set to bundle--ActorSystem
.
clazz
parameter.
org.apache.camel.impl.DefaultCamelContext
CamelContext
.
Class[_]
object loaded with the right class loader (i.e.
ActorContext
for this pipeline’s context.
isErrorClosed
returns true, then the error condition can be
retrieved by this method.
name
parameter.
names
.
LoggingAdapter
for this pipeline’s context.
n
bytes were encoded.
org.apache.camel.ProducerTemplate
ProducerTemplate
.
ActorRef
of the actor replying to the request or
null if no actor matched the request.
ActorRef
.
Mapper
function that will be used as a route definition handler
for creating custom route to this consumer.
TimerTask
which is associated with this handle.
Timer
that created this handle.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
true
), or it returns false
to escalate the
failure, which will lead to this actor re-throwing the exception which
caused the failure.
hashCode
.hashCode
.AckedSendBuffer
or AckedReceiveBuffer
has
to implement this interface to provide the sequence needed by the buffers.name
parameter in a Try
.
names
.
requiring
methods.HighWatermark
option shall set the high water mark for the specified socket.ActorIdentity
containing the ActorRef
.Identity
valueSystem.identityHashCode
,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
System.identityHashCode
,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
Iterable
into an immutable Scala sequence (by copying it).
Iterable
into an immutable Scala sequence (by copying it).
akka.actor.dsl.Inbox!.Inbox!.receive
and akka.actor.dsl.Inbox!.Inbox!.select
methods.
Actor
subclass.Inet.SocketOption
to set the SO_RCVBUF optionInet.SocketOption
to enable or disable SO_REUSEADDRInet.SocketOption
to set the SO_SNDBUF option.Inet.SocketOption
to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Info events, the most efficient is to use Left("")
.null
is an invalid message.IOManager
to accept a new connection with the
given IO.SocketOption
s.IO.ServerSocketOption
to set the maximum backlog of connections.IO.Input
stream that contains a chunk of bytes.IOManager
to close the Channel.IOManager
that the Channel has closed.IOManager
to create a SocketChannel connected
to the provided address with the given IO.SocketOption
s.IOManager
that the SocketChannel has
successfully connected.IO.Input
stream that represents the end of the
stream.IO.Input
stream that represents an error in the stream.IO.Iteratee
that represents an erronous end state.IO.Iteratee
.IOManager
.IO.Iteratee
.IO.Iteratee
.IO.SocketOption
to enable or disable SO_KEEPALIVEIOManager
to create a ServerSocketChannel
listening on the provided address with the given
IO.ServerSocketOption
s.IOManager
that the ServerSocketChannel is
now listening for connections.IOManager
that a new connection has been
made to the ServerSocketChannel and needs to be accepted.IO.Iteratee
that still requires more input to calculate
it's result.IO.SocketOption
to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data received on a IO.SocketHandle
is silently discarded.IO.SocketOption
to set performance preferences for this
IO.SocketHandle
.IOManager
that contains bytes read from
the SocketChannel.IO.Handle
to a ReadableByteChannel.IO.SocketOption
to set the SO_RCVBUF option for this
IO.SocketHandle
.IO.SocketOption
to enable or disable SO_REUSEADDRIO.SocketOption
to set the SO_SNDBUF option for this
IO.SocketHandle
.IO.Handle
to a ServerSocketChannel.IO.ServerHandle
IO.Handle
to a SocketChannel.IO.SocketHandle
IO.SocketOption
to enable or disable SO_LINGER with the
specified linger time in seconds.IO.SocketOption
to set SO_TIMEOUT to the specified
timeout rounded down to the nearest millisecond.IO.SocketOption
to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)IO.SocketOption
to set the traffic class or
type-of-service octet in the IP header for packets sent from this
IO.SocketHandle
.IOManager
to write to the SocketChannel.IO.Handle
to a WritableByteChannel.IOManagerActor
for
an ActorSystem
.Actor
that performs IO using a Java NIO Selector.true
iff the connection has been closed in response to an Abort
command.
Down
and not Removed
.
true
if and only if the TimerTask
associated
with this handle has been cancelled.
true
iff the connection has been fully closed in response to a
ConfirmedClose
command.
true
iff the connection has been closed due to an IO error.
true
if and only if the TimerTask
associated
with this handle has been expired.
true
iff the connection has been closed by the peer; in case
keepOpenOnPeerClosed
is in effect as per the Tcp.Register
command,
this connection’s reading half is now closed.
java.util.logging
logger.Logging
API available as the log
field, using java.util.logging
as the backend.isCheck == true
and the latter to isCheck == false
for those cases where
this is important to know.true
or the
timeout expires, whichever comes first.match
function or the idle timeout is met (disabled by
default) or the overall maximum duration is elapsed.min
and max
.ExtendedActorSystem
, because
that is the preferred constructor which will be invoked when reflectively instantiating
the JSerializer (also possible with empty constructor).Inet.SocketOption
to enable or disable SO_KEEPALIVE
Inet.SocketOption
to enable or disable SO_KEEPALIVE
TestTransport.AssociationRegistry
to identify associations.
TestTransport.SwitchableLoggedBehavior
for the listen() method.
ActorSystem.eventStream
.
SupervisorStrategy.loggingEnabled()
is true
.
true
.
FSM
which adds a rolling event log and
debug logging capabilities (analogous to LoggingReceive
).Logging
’s apply
/create
method.FSM.Failure
is logged at error level and other reason
types are not logged.
LookupClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeDeploy
instance.
ActorSystem
with one
top level application supervisor actor.ActorSystem
with one
top level application supervisor actor.PipelineContext
necessary for the operation of the given PipelineStage
.
transformer
function.
transformer
function.
true
) or not
(false
).
DistributedPubSubMediator
MulticastHops
MulticastLoop
testconductor
, or helper methods that use testconductor
,
from the constructor of your test class.Props
to build a ZeroMQ Dealer socket actor.
Props
to build a ZeroMQ Publisher socket actor.
Props
to build a ZeroMQ Pull socket actor.
Props
to build a ZeroMQ Push socket actor.
Props
to build a ZeroMQ Rep socket actor.
Props
to build a ZeroMQ Req socket actor.
Props
to build a ZeroMQ Router socket actor.
Props
to build the ZeroMQ socket actor.
Props
to build a ZeroMQ Subscriber socket actor.
TimerTask
for one-time execution after
the specified delay.
Tcp.WriteCommand
can optionally request a positive acknowledgment to be sent
to the commanding actor.
Tcp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
Tcp.WriteCommand
can optionally request a positive acknowledgment to be sent
to the commanding actor.
Tcp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
UdpConnected.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.
UdpConnected.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
UdpConnected.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.
UdpConnected.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
Udp.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.
Udp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
Udp.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.
Udp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.
Option
factory that creates None
Option
factory that creates None
ActorRef.tell(java.lang.Object, akka.actor.ActorRef)
if there is not actor to
reply to (e.g.
ActorRef.tell(java.lang.Object, akka.actor.ActorRef)
if there is not actor to
reply to (e.g.
Iterable[Either[EvtAbove, CmdBelow}
.
System.nanoTime
) as Duration.
Directive
(Resume, Restart, Stop) specified in the Decider
to the child actor that failed, as opposed to AllForOneStrategy
that applies
it to all children.endpointUri
.
getEndpointUri
.
Inet.SocketOption
to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.
Inet.SocketOption
to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.
Option
factory that creates None
if
v
is null
, Some(v)
otherwise.
Option
factory that creates None
if
v
is null
, Some(v)
otherwise.
Some[A]
represents existing values of type
A
.Member
ordering type class, sorts members by host and port.
Member
ordering type class, sorts members by host and port.
ByteString
of the request length,
but does not consume the Input.
ByteString
of the request length,
but does not consume the Input.
PinnedDispatcher
.Future
to send
the result to the given ActorRef
or ActorSelection
.
Future
to send
the result to the given ActorRef
or ActorSelection
.
pipeTo
method on Future
:
PipelineStage
into readily usable pipelines.PipelineStage
into readily usable pipelines.PipelineFactory.buildWithSink(Ctx, akka.io.PipelineStage, akka.io.PipelineSink)
to a
pipeline when it is being built.PipePair
instances; those are needed within the implementation of PipelineStage.apply(Context)
.PipePair
instances; those are needed within the implementation of PipelineStage.apply(Context)
.TestConductorExt
extension.preStart()
.
preStart()
.
preStart()
.
onTermination
hook; if you want to retain this behavior when
overriding make sure to call super.postStop()
.
Write
or WriteFile
to form
a CompoundWrite
.
postStop()
.'''
postStop()
.'''
postStop()
.'''
Is called on a crashed Actor right BEFORE it is restarted to allow clean
up of resources before Actor is terminated.
msg
to the endpoint specified by endpointUri
.
pattern
with the endpoint specified by
endpointUri
.
Actor
; it is
immutable, so it is thread-safe and fully shareable.Props.create(clazz, args ...)
instead
Props.create(clazz, args ...)
instead; this method has been
deprecated because it encourages creating Props which contain
non-serializable inner classes, making them also
non-serializable
ClusterClient
Props
.
ClusterClient
Props
.
ClusterClient
Props
.
ClusterClient
Props
.
ClusterReceptionist
Props
.
ClusterReceptionist
Props
.
ClusterReceptionist
Props
with default values.
ClusterReceptionist
Props
.
ClusterReceptionist
Props
.
ClusterReceptionist
Props
with default values.
ClusterSingletonManager
Props
.
ClusterSingletonManager
Props
.
ClusterSingletonManager
Props
.
ClusterSingletonManager
Props
.
DistributedPubSubMediator
Props
.
DistributedPubSubMediator
Props
.
DistributedPubSubMediator
Props
.
DistributedPubSubMediator
Props
.
Props
for a pipeline handler
Props
for a pipeline handler
com.google.protobuf.Message
sClusterEvent.ClusterDomainEvent
or ClusterEvent.CurrentClusterState
.
n
least significant bytes of the given Long to this builder.
rampupRate
.
AssociationHandle.HandleEventListener
to register a listener responsible for handling incoming payload.
become
to change this.
receiver
actor.
Inet.SocketOption
to set the SO_RCVBUF option
Inet.SocketOption
to set the SO_RCVBUF option
ReceiveBufferSize
option shall set the underlying kernel receive buffer size for the socket to
the specified size in bytes.ReceiveBufferSize
ReceiveHighWatermark
option shall set the high water mark for inbound messages on the specified socket.receiveN(n, remaining())
, but correctly treating the
timeFactor.
receiveN(n, remaining)
but correctly taking into account
Duration.timeFactor.
ReconnectIVLMax
option shall set the maximum reconnection interval for the specified socket.RecoveryInterval
DynamicAccess
implementation used by ExtendedActorSystem
unless overridden.Tcp.Connected
message.
register(handler, false, false)
.
Tcp.Connected
message.
register(handler, false, false)
.
Up
.
Up
.
Within
block or missing that it returns the properly dilated
default for this case from settings (key
"akka.test.single-expect-default").
within
block or missing that it returns the properly dilated default for this
case from settings (key "akka.test.single-expect-default").
Within
block or missing that it returns the given duration.
within
block or missing that it returns the given duration.
RouterConfig
implementation for remote deployment on defined
target nodes.RemoteTransportException
without stack trace.PoisonPill
after the specified delay.
value
.
RouterConfig
.Resizer
to use.
ActorRef
matching this selection.
ActorRef
matching this selection.
Tcp.SuspendReading
command in order to resume reading from the socket.
Tcp.SuspendReading
command in order to resume reading from the socket.
UdpConnected.SuspendReading
command.
UdpConnected.SuspendReading
command.
Udp.SuspendReading
command.
Udp.SuspendReading
command.
useResumeWriting
is in effect as was indicated in the Tcp.Register
message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed
event.
useResumeWriting
is in effect as was indicated in the Tcp.Register
message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed
event.
Inet.SocketOption
to enable or disable SO_REUSEADDR
Inet.SocketOption
to enable or disable SO_REUSEADDR
Router
actors.Deploy
instance.
endpointUri
.
Timer#newTimeout(TimerTask, long, java.util.concurrent.TimeUnit)
.
roleMap
).
that
is tracking the same metric as this.
that
address is the same as this
ScanningClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeDeploy
serves two purposes: as a marker for
pattern matching the “scope” (i.e.receiver
actor.
Udp.SimpleSender
query to the UdpExt.manager()
as well as by
the listener actors which are created in response to Udp.Bind
.
send(payload, target, noAck())
.
Udp.SimpleSender
query to the UdpExt.manager()
as well as by
the listener actors which are created in response to Udp.Bind
.
send(payload, target, noAck())
.
Inet.SocketOption
to set the SO_SNDBUF option.
Inet.SocketOption
to set the SO_SNDBUF option.
SendBufferSize
option shall set the underlying kernel transmit buffer size for the socket to
the specified size in bytes.SendBufferSize
SendHighWatermark
option shall set the high water mark for outbound messages on the specified socket.Seq
of Cause-Directive pairs to a Decider
.
Seq
of Throwables to a Decider
.
Seq
of Throwables to a Decider
.
Futures$.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext)
.
Futures.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext)
.
ActorRef
to Akka's
protobuf representation.
ActorRef
to Akka's
protobuf representation.
DynamicAccess
.
ReceiveTimeout
message is triggered.
TestTransport.SwitchableLoggedBehavior
for the shutdown() method.
Option
factory that creates Some
Option
factory that creates Some
SSLEngine
.akka.testconductor.host
).
Controller
, which in turn will
bind to a TCP port as specified in the akka.testconductor.port
config
property, where 0 denotes automatic allocation.
Stash
trait enables an actor to temporarily stash away messages that can not or
should not be handled using the actor's current behavior.ActorRef
; this is
an asynchronous operation, i.e.
Timer
and cancels all
tasks which were scheduled but not executed yet.
SubchannelClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeSubscribe
option establishes a new message filter on a akka.zeromq.SocketType.Pub
socket./user
).Udp.Bound
message) to
have it stop reading datagrams from the network.
Udp.Bound
message) to
have it stop reading datagrams from the network.
Udp.Bound
message) to
have it stop reading datagrams from the network.
Udp.Bound
message) to
have it stop reading datagrams from the network.
Swap
option shall set the disk offload (swap) size for the specified socket.Swap
PipelineStage
which is symmetric in command and event types, i.e.PipePair
which has the same types
for commands and events.IO.IterateeRefSync
containing an initial
IO.Iteratee
.
IO.IterateeRefSync
.
IO.IterateeRefSync
for each new key.
Abort
command.TcpExt.manager()
in order to bind to a listening socket.Tcp.Bind
command will—in case of success—receive confirmation
in this form.Close
command.ConfirmedClose
command.TcpExt.manager()
.Tcp.Connect
command (for outbound) or to the handler for incoming connections designated
in the Tcp.Bind
message.Tcp.WriteCommand
and Tcp.Event
.Tcp.WriteCommand
can optionally request a positive acknowledgment to be sent
to the commanding actor.Tcp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.Tcp.Register
message.Tcp.Connected
message.SuspendReading
command in order to resume reading from the socket.useResumeWriting
is in effect as was indicated in the Tcp.Register
message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed
event.Tcp.Write
and Tcp.WriteFile
.Inet.SocketOption
to enable or disable SO_KEEPALIVEInet.SocketOption
to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.Inet.SocketOption
to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)Tcp.Bound
message).Unbind
command will receive confirmation through this
message once the listening socket has been closed.Tcp.Write
, Tcp.WriteFile
and Tcp.CompoundWrite
.count
bytes starting at position
from file at filePath
to the connection.useResumeWriting
is in effect as indicated in the Tcp.Register
message,
the ResumeWriting
command will be acknowledged by this message type, upon
which it is safe to send at least one write.Inet.SocketOption
to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)
Inet.SocketOption
to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)
Tcp
connection actor.TcpPipelineHandler
actor.TcpPipelineHandler
actor.TcpPipelineHandler
actor.Tcp.Event
to the registered handler
actor, which is enabled by emitting this Tcp.Command
wrapping an event
instead.Terminated
to non-watching testActor is not possible,
and therefore the Terminated
message is wrapped.Terminated
to non-watching testActor is not possible,
and therefore the Terminated
message is wrapped.TestConductorExt
extension:TestConductorExt
extension:Conductor
and
Player
roles inside an Akka
Extension
.Mute
to the TestEventListener to install a filter, and UnMute
to
deinstall it.Mute
to the TestEventFilter to install a filter, and UnMute
to
deinstall it.TestKit
class: you may use
this if inheriting from a concrete class is not possible.blackhole
, passThrough
, and throttle
you must
activate the failure injector and throttler transport adapters by
specifying testTransport(on = true)
in your MultiNodeConfig.
TestTransport
.TestTransport
instances.Throttler.Rate
).Throttler.Rate
).Inet.SocketOption
to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.
Inet.SocketOption
to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.
endpointUri
.
ActorRef
instances to an AssociationEventListener.Transport.AssociationEventListener
registered to a transport
(via the Promise returned by akka.remote.transport.Transport.listen
) when an inbound association request arrives.TypedActor.MethodCall
to the provided ActorRef.
UdpExt.manager()
in order to bind to the given
local port (or an automatically assigned one if the port number is zero).Udp.Bind
command.Udp.Command
and Udp.Event
.Udp.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.Udp.NoAck
instance which is used when no acknowledgment information is
explicitly provided.Udp.Bind
message using this message type.SuspendReading
command.Udp.SimpleSender
query to the UdpExt.manager()
as well as by
the listener actors which are created in response to Udp.Bind
.Udp.SimpleSender
query.Inet.SocketOption
to set the SO_BROADCAST optionUdp.Bound
message) to
have it stop reading datagrams from the network.Udp.Bound
message in order to close the listening socket.Unbind
command
after the socket has been closed.UdpExt.manager()
in order to bind to a local
port (optionally with the chosen localAddress
) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress
.UdpConnected.Connect
message when the UDP socket has been bound to the local and
remote addresses given.UdpConnected.Connected
message) in order to close the socket.Disconnect
message when the UDP socket has been closed.UdpConnected.Command
and UdpConnected.Event
.UdpConnected.Send
can optionally request a positive acknowledgment to be sent
to the commanding actor.UdpConnected.NoAck
instance which is used when no acknowledgment information is
explicitly provided.Udp.Bind
message using this message type.SuspendReading
command.Udp.Bound
message) to
have it stop reading datagrams from the network.Tcp.Bound
message).
Tcp.Bound
message).
Udp.Bound
message in order to close the listening socket.
Udp.Bound
message in order to close the listening socket.
UnboundedStash
trait is a version of Stash
that enforces an unbounded stash for you actor.UntypedActor.onReceive(java.lang.Object)
(e.g.
Stash
that does not enforce any mailbox type.subscribe
registration.
Unsubscribe
option shall remove an existing message filter
on a akka.zeromq.SocketType.Sub
socket.Stash
that enforces an unbounded deque for the actor.Stash
that does not enforce any mailbox type.true
to assert that the
shutdown of the ActorSystem
was done properly.
Tcp.WriteCommand.ack()
token not being a of type Tcp.NoAck
.
source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Warning events, the most efficient is to use Left("")
.preRestart
action with the supplied function.
postRestart
action with the supplied function.
preStart
action with the supplied thunk.
postStop
action with the supplied thunk.
body
converted to type T
.
body
converted to type clazz
.
Props.create(clazz, args ...)
instead; this method has been
deprecated because it encourages creating Props which contain
non-serializable inner classes, making them also
non-serializable
Deploy
instances using
withFallback()
on
the left one, this is propagated to “merging” scopes in the same way.
headers
.
min
and
max
.
within(0 seconds, max)(f)
.
uid
.
ConsistentHash
IOManager
to write to the
Channel associated with this IO.Handle
.
write(data, noAck())
.
write(data, noAck())
.
TestTransport.SwitchableLoggedBehavior
for the write() method on handles.
count
bytes starting at position
from file at filePath
to the connection.
count
bytes starting at position
from file at filePath
to the connection.
ExtensionId
and ExtensionIdProvider
for the ZeroMQ module
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |