server/io.spine.server.delivery/LocalDispatchingObserver

LocalDispatchingObserver

public final class LocalDispatchingObserver implements ShardObserver

An observer of changes to the shard contents, which triggers immediate delivery of the sharded messages.

Depending on the configuration, the delivery may be triggered either synchronously or asynchronously.

Suitable for the local and development environment.

Constructors

Link copied to clipboard
public void LocalDispatchingObserver()
Creates a new observer instance which performs the delivery synchronously.

Functions

Link copied to clipboard
public void onMessage(InboxMessage update)
A callback executed once the message was written into the shard.