org.eligosource.eventsourced.core
Processor id.
Processor id.
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.
Calls super.postStop
and then de-registers this processor from
org.eligosource.eventsourced.core.EventsourcingExtension.
Calls super.postStop
and then de-registers this processor from
org.eligosource.eventsourced.core.EventsourcingExtension.
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.
Java API.
Base class for untyped actors, modified with org.eligosource.eventsourced.core.Emitter and org.eligosource.eventsourced.core.Eventsourced.