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|
Creates a new observer instance which performs the delivery synchronously.
|Modifier and Type||Method and Description|
A callback executed once the message was written into the shard.
public void onMessage(io.spine.server.delivery.InboxMessage update)
Allows the descendants to react upon this update. E.g. by scheduling a delivery from the shard with the specified index.