io.spine.server.delivery

Class LocalDispatchingObserver

java.lang.Object

io.spine.server.delivery.LocalDispatchingObserver

All Implemented Interfaces:

ShardObserver

public final class LocalDispatchingObserver
extends java.lang.Object
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.

Constructor Summary

Constructors

Constructor and Description
LocalDispatchingObserver() Creates a new observer instance which performs the delivery synchronously.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalDispatchingObserver

public LocalDispatchingObserver()

Creates a new observer instance which performs the delivery synchronously.

Method Detail

onMessage

public void onMessage(io.spine.server.delivery.InboxMessage update)

Description copied from interface: ShardObserver

A callback executed once the message was written into the shard.

Allows the descendants to react upon this update. E.g. by scheduling a delivery from the shard with the specified index.

Specified by:

onMessage in interface ShardObserver

Parameters:

update - the message with which some shard was updated