public final class LocalDispatchingObserver extends java.lang.Object implements ShardObserver
Depending on the configuration, the delivery may be triggered either synchronously or asynchronously.
Suitable for the local and development environment.
Constructor and Description |
---|
LocalDispatchingObserver()
Creates a new observer instance which performs the delivery synchronously.
|
Modifier and Type | Method and Description |
---|---|
void |
onMessage(io.spine.server.delivery.InboxMessage update)
A callback executed once the message was written into the shard.
|
public LocalDispatchingObserver()
public void onMessage(io.spine.server.delivery.InboxMessage update)
ShardObserver
Allows the descendants to react upon this update. E.g. by scheduling a delivery from the shard with the specified index.
onMessage
in interface ShardObserver
update
- the message with which some shard was updated