Java API.
Java API.
Waits for all processors to finish processing of all pending messages in their mailboxes.
maximum duration to wait for processing to complete.
Java API.
Java API.
Waits for specified processors to finish processing of all pending messages in their mailboxes.
ids of registered processors to wait for. Default value is the set of all registered processor ids.
maximum duration to wait for processing to complete.
Waits for specified processors to finish processing of all pending messages in their mailboxes.
Waits for specified processors to finish processing of all pending messages in their mailboxes.
ids of registered processors to wait for. Default value is the set of all registered processor ids.
maximum duration to wait for processing to complete. Default value is 1 minute.
Creates and registers a org.eligosource.eventsourced.core.Channel.
Creates and registers a org.eligosource.eventsourced.core.Channel. The channel is
registered under the id specified by props.id
. If props.name
is defined it is also
registered under that name.
channel configuration object.
org.eligosource.eventsourced.core.Channel ref factory.
a channel ref.
if name
is defined and already in use
in the underlying actor system.
if channel id < 1.
org.eligosource.eventsourced.core.DefaultChannelProps org.eligosource.eventsourced.core.ReliableChannelProps
Map of registered org.eligosource.eventsourced.core.Channels.
Map of registered org.eligosource.eventsourced.core.Channels. Mapping key is the channel id.
Java API.
Java API.
Returns a Future
that will be completed when all processors have finished
processing all pending messages in their mailboxes.
Java API.
Java API.
Returns a Future
that will be completed when specified processors have finished
processing all pending messages in their mailboxes.
ids of registered processors to wait for. Default value is the set of all registered processor ids.
Returns a Future
that will be completed when specified processors have finished
processing all pending messages in their mailboxes.
Returns a Future
that will be completed when specified processors have finished
processing all pending messages in their mailboxes.
ids of registered processors to wait for. Default value is the set of all registered processor ids.
Java API.
Java API.
Activates the specified channels and starts delivery of pending messages.
Activates the specified channels and starts delivery of pending messages.
Activates the channel registered under channelId
and starts delivery of pending messages.
Activates all registered channels and starts delivery of pending messages.
Java API.
Java API.
Map of registered org.eligosource.eventsourced.core.Channels. Mapping key is the channel id.
Java API.
Java API.
Map of registered named org.eligosource.eventsourced.core.Channels. Mapping key is the channel name.
Java API.
Java API.
Map of registered org.eligosource.eventsourced.core.Eventsourced processors. Mapping key is the processor id.
Java API.
Java API.
Predefined ReplayParams
sequences to be used with methods replay
or recover
.
Journal for this extension.
Map of registered named org.eligosource.eventsourced.core.Channels.
Map of registered named org.eligosource.eventsourced.core.Channels. Mapping key is the channel name.
Java API.
Java API.
Registers an org.eligosource.eventsourced.core.Eventsourced processor with a specified actor name.
This method obtains the id from the created processor with a blocking operation.
Use the overloaded processorOf(ProcessorProps)
method if you want to avoid
blocking.
actor ref configuration object.
processor name.
org.eligosource.eventsourced.core.Eventsourced ref factory.
a processor ref.
if name
is defined and already in use
in the underlying actor system.
if processor id < 1.
Java API.
Java API.
Registers an org.eligosource.eventsourced.core.Eventsourced processor with a generated actor name.
This method obtains the id from the created processor with a blocking operation.
Use the overloaded processorOf(ProcessorProps)
method if you want to avoid
blocking.
actor ref configuration object.
org.eligosource.eventsourced.core.Eventsourced ref factory.
a processor ref.
if name
is defined and already in use
in the underlying actor system.
if processor id < 1.
Registers an org.eligosource.eventsourced.core.Eventsourced processor.
Registers an org.eligosource.eventsourced.core.Eventsourced processor.
This method obtains the id from the created processor with a blocking operation.
Use the overloaded processorOf(ProcessorProps)
method if you want to avoid
blocking.
actor ref configuration object.
optional processor name. If None
, a name is generated.
org.eligosource.eventsourced.core.Eventsourced ref factory.
a processor ref.
if name
is defined and already in use
in the underlying actor system.
if processor id < 1.
Registers an org.eligosource.eventsourced.core.Eventsourced processor.
Registers an org.eligosource.eventsourced.core.Eventsourced processor.
processor configuration object.
a processor ref.
if props.name
is defined and already
in use in the underlying actor system.
if processor id < 1.
Map of registered org.eligosource.eventsourced.core.Eventsourced processors.
Map of registered org.eligosource.eventsourced.core.Eventsourced processors. Mapping key is the processor id.
Java API.
Java API.
Recovers specified processors and all channels registered at this extension where
replay(params)
deliver()
Channel activation is only started after processor recovery successfully completed.
This method waits for replayed messages being sent to specified processors (via !
)
and all channels being activated but does not wait for replayed input messages being
processed. However, any new message sent to any of the specified processors, after
this method successfully returned, will be processed after the replayed event messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after this method successfully returned.
replay parameters passed to replay(params)
.
wait for the specified duration for the replay to complete.
if replay doesn't complete within the specified duration.
Recovers specified processors and all channels registered at this extension where
Recovers specified processors and all channels registered at this extension where
replay(params)
deliver()
Channel activation is only started after processor recovery successfully completed.
This method waits for replayed messages being sent to specified processors (via !
)
and all channels being activated but does not wait for replayed input messages being
processed. However, any new message sent to any of the specified processors, after
this method successfully returned, will be processed after the replayed event messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after this method successfully returned.
replay parameters passed to replay(params)
.
wait for the specified duration for the replay to complete.
if replay doesn't complete within the specified duration.
Recovers specified processors and all channels registered at this extension where
Recovers specified processors and all channels registered at this extension where
replay(params)
deliver()
Channel activation is only started after processor recovery successfully completed.
This method waits for replayed messages being sent to specified processors (via !
)
and all channels being activated but does not wait for replayed input messages being
processed. However, any new message sent to any of the specified processors, after
this method successfully returned, will be processed after the replayed event messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after this method successfully returned.
replay parameters passed to replay(params)
.
if replay doesn't complete within 1 minute.
Recovers all processors and all channels registered at this extension where
Recovers all processors and all channels registered at this extension where
replay(params)
deliver()
Channel activation is only started after processor recovery successfully completed.
This method waits for replayed messages being sent to all processors (via !
)
and all channels being activated but does not wait for replayed input messages being
processed. However, any new message sent to any of the processors, after this method
successfully returned, will be processed after the replayed event messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after this method successfully returned.
if replay doesn't complete within the specified duration (which defaults to 1 minute).
Recovers all processors and all channels registered at this extension where
Recovers all processors and all channels registered at this extension where
replay(params)
deliver()
Channel activation is only started after processor recovery successfully completed.
This method waits for replayed messages being sent to all processors (via !
)
and all channels being activated but does not wait for replayed input messages being
processed. However, any new message sent to any of the processors, after this method
successfully returned, will be processed after the replayed event messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after this method successfully returned.
wait for the specified duration for the replay to complete.
if replay doesn't complete within the specified duration.
Java API.
Java API.
Replays input messages to specified processors, optionally based on a snapshot.
The returned Future
will be completed when the replayed messages have been
sent (via !
) to the specified processors. Any new message sent to any of the
specified processors, after successful completion of the returned Future
, will
be processed after the replayed input messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after the returned Future
successfully completed.
sequence of processor-specific replay parameters.
Replays input messages to specified processors, optionally based on a snapshot.
Replays input messages to specified processors, optionally based on a snapshot.
The returned Future
will be completed when the replayed messages have been
sent (via !
) to the specified processors. Any new message sent to any of the
specified processors, after successful completion of the returned Future
, will
be processed after the replayed input messages.
Clients that want to wait for replayed messages being processed should call the
awaitProcessing
method after the returned Future
successfully completed.
sequence of processor-specific replay parameters.
Predefined ReplayParams
sequences to be used with methods replay
or recover
.
Java API.
Java API.
Requests a snapshot capturing action from specified processors. These processors
will receive a org.eligosource.eventsourced.core.SnapshotRequest message which
is used to capture a snapshot via that message's process
method. Once captured,
the snapshots will be saved. The future returned by this method will be completed,
when all snapshots have been saved.
Calling this method for a single processor is equivalent to sending that
processor a SnapshotRequest.get
message.
ids of processors for which a snapshot capturing action shall be requested.
snapshot capturing and saving timeout.
Requests a snapshot capturing action from specified processors.
Requests a snapshot capturing action from specified processors. These processors
will receive a org.eligosource.eventsourced.core.SnapshotRequest message which
is used to capture a snapshot via that message's process
method. Once captured,
the snapshots will be saved. The future returned by this method will be completed,
when all snapshots have been saved.
Calling this method for a single processor is equivalent to sending that processor a org.eligosource.eventsourced.core.SnapshotRequest$ message.
ids of processors for which a snapshot capturing action shall be requested.
snapshot capturing and saving timeout.
(Since version 0.5) use recover(Seq[ReplayParams], FiniteDuration)
(Since version 0.5) use replay(Seq[ReplayParams])(Timeout)
Event-sourcing extension for Akka. Used by applications to create and register org.eligosource.eventsourced.core.Eventsourced processors and event message org.eligosource.eventsourced.core.Channels and to recover them from journaled event org.eligosource.eventsourced.core.Messages and, optionally, snapshots.