io.spine.server.delivery

Class ShardProcessingSession

java.lang.Object

io.spine.server.delivery.ShardProcessingSession

@SPI
public abstract class ShardProcessingSession
extends java.lang.Object

The session of processing the messages, which reside in a shard.

Starts by picking up the shard to process.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ShardProcessingSession(io.spine.server.delivery.ShardSessionRecord record)

Method Summary

Modifier and Type	Method and Description
protected abstract void	complete() Completes this session and releases the picked shard, making it available for picking up.
io.spine.server.delivery.ShardIndex	shardIndex() Returns the index of the shard, to which this session relates to.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardProcessingSession

protected ShardProcessingSession(io.spine.server.delivery.ShardSessionRecord record)

Method Detail

shardIndex

public io.spine.server.delivery.ShardIndex shardIndex()

Returns the index of the shard, to which this session relates to.

complete

protected abstract void complete()

Completes this session and releases the picked shard, making it available for picking up.