public class JdbcInboxStorage extends JdbcMessageStorage<io.spine.server.delivery.InboxMessageId,io.spine.server.delivery.InboxMessage,io.spine.server.delivery.InboxReadRequest,io.spine.server.storage.jdbc.delivery.InboxTable> implements io.spine.server.delivery.InboxStorage
InboxStorage
.
All inbox messages reside in a separate SQL table.
Modifier and Type | Class and Description |
---|---|
static class |
JdbcInboxStorage.Builder |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static JdbcInboxStorage.Builder |
newBuilder() |
io.spine.server.delivery.Page<io.spine.server.delivery.InboxMessage> |
readAll(io.spine.server.delivery.ShardIndex index) |
index, read, removeAll, table, write, write, writeAll
checkNotClosed, checkNotClosed, isClosed, isMultitenant, isOpen
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public io.spine.server.delivery.Page<io.spine.server.delivery.InboxMessage> readAll(io.spine.server.delivery.ShardIndex index)
readAll
in interface io.spine.server.delivery.InboxStorage
public void close()
Closes the underlying data source.
close
in interface io.spine.server.storage.Storage<io.spine.server.delivery.InboxMessageId,io.spine.server.delivery.InboxMessage,io.spine.server.delivery.InboxReadRequest>
close
in interface java.lang.AutoCloseable
close
in class io.spine.server.storage.AbstractStorage<io.spine.server.delivery.InboxMessageId,io.spine.server.delivery.InboxMessage,io.spine.server.delivery.InboxReadRequest>
public static JdbcInboxStorage.Builder newBuilder()