public class JdbcShardedWorkRegistry extends JdbcMessageStorage<io.spine.server.delivery.ShardIndex,io.spine.server.delivery.ShardSessionRecord,io.spine.server.storage.jdbc.delivery.ShardSessionReadRequest,io.spine.server.storage.jdbc.delivery.ShardedWorkRegistryTable> implements io.spine.server.delivery.ShardedWorkRegistry
ShardedWorkRegistry
.
Represents an SQL table of session records with the appropriate accessor methods.
Modifier and Type | Class and Description |
---|---|
static class |
JdbcShardedWorkRegistry.Builder |
Modifier and Type | Method and Description |
---|---|
static JdbcShardedWorkRegistry.Builder |
newBuilder() |
java.util.Optional<io.spine.server.delivery.ShardProcessingSession> |
pickUp(io.spine.server.delivery.ShardIndex index,
io.spine.server.NodeId nodeId) |
index, read, removeAll, table, write, write, writeAll
public java.util.Optional<io.spine.server.delivery.ShardProcessingSession> pickUp(io.spine.server.delivery.ShardIndex index, io.spine.server.NodeId nodeId)
pickUp
in interface io.spine.server.delivery.ShardedWorkRegistry
public static JdbcShardedWorkRegistry.Builder newBuilder()