org.eligosource.eventsourced.core
Java API.
Java API.
Puts behavior
on the hotswap stack. This will preserve the behavior of this stackable
trait. Actors that additionally want to replace the behavior of this stackable trait should
call getContext().become(...)
.
new behavior
if true
, unbecome()
will be called prior to pushing behavior
.
Java API.
Java API.
Puts behavior
on the hotswap stack. This will preserve the behavior of this stackable
trait. Actors that additionally want to replace the behavior of this stackable trait should
call getContext().become(...)
. The existing (old) behavior will be discarded.
new behavior
Puts behavior
on the hotswap stack.
Puts behavior
on the hotswap stack. This will preserve the behavior of this stackable
trait. Actors that additionally want to replace the behavior of this stackable trait should
call context.become(...)
.
new behavior
if true
, unbecome()
will be called prior to pushing behavior
.
Returns a map of registered org.eligosource.eventsourced.core.Channels.
Returns a map of registered org.eligosource.eventsourced.core.Channels. Mapping key is the channel id.
Positively or negatively confirms the receipt of the current event message.
Positively or negatively confirms the receipt of the current event message.
true
for a positive receipt confirmation, false
for a negative one.
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
Returns a message emitter that captures the current event message
and a channel
that has been registered under channelName
.
Returns a message emitter that captures the current event message
and a channel
that has been registered under channelName
. If no channel exists for channelName
it will be context.system.deadLetters
. Applications can run the returned emitter
from within any thread for sending output messages (which will be derived from the
captured event message
).
Returns a message emitter that captures the current event message
and a channel
that has been registered under channelId
.
Returns a message emitter that captures the current event message
and a channel
that has been registered under channelId
. If no channel exists for channelId
it will be context.system.deadLetters
. Applications can run the returned emitter
from within any thread for sending output messages (which will be derived from the
captured event message
).
Returns a message emitter factory that captures the current event message
and the
map of registered channels
.
Returns a message emitter factory that captures the current event message
and the
map of registered channels
. Applications can run the returned emitter factory
from within any thread.
Current event message.
Current event message.
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
messageOption
Current event message option.
Current event message option. None
if the last message received by this receiver
is not of type org.eligosource.eventsourced.core.Message.
Returns a map of registered named org.eligosource.eventsourced.core.Channels.
Returns a map of registered named org.eligosource.eventsourced.core.Channels. Mapping key is the channel name.
Sequence number of current event message
Sequence number of current event message
if the the last message received by this receiver is not of type org.eligosource.eventsourced.core.Message
Reverts the behavior to the previous one on the hotswap stack.
Reverts the behavior to the previous one on the hotswap stack. This will preserve the behavior of this stackable trait.
Stackable modification for actors to provide convenient access to registered org.eligosource.eventsourced.core.Channels and to emit event org.eligosource.eventsourced.core.Messages to these channels. Registered channels are those that have been created with the
EventsourcingExtension.channelOf
method.Applications may also use org.eligosource.eventsourced.core.Channel actor references directly to emit event messages to destinations (using the
!
,?
orforward
methods onActorRef
).The
Emitter
trait can also be used in combination with other stackable traits of the library (such as org.eligosource.eventsourced.core.Confirm or org.eligosource.eventsourced.core.Eventsourced), for example:org.eligosource.eventsourced.core.MessageEmitter org.eligosource.eventsourced.core.MessageEmitterFactory