com.lightbend.lagom.javadsl.persistence.jdbc

Interface JdbcReadSide

public interface JdbcReadSide

JDBC read side support. This should be used to build and register a read side processor. All callbacks are executed in a transaction and are automatically committed or rolled back based on whether they fail or succeed. Offsets are automatically handled.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	JdbcReadSide.ConnectionBiConsumer<T> SAM for consuming a connection and a parameter
static interface	JdbcReadSide.ConnectionConsumer SAM for consuming a connection.
static interface	JdbcReadSide.ConnectionTriConsumer<T,U> SAM for consuming a connection and two other parameters
static interface	JdbcReadSide.ReadSideHandlerBuilder<Event extends AggregateEvent<Event>> Builder for the handler.

Method Summary

Modifier and Type	Method and Description
<Event extends AggregateEvent<Event>> JdbcReadSide.ReadSideHandlerBuilder<Event>	builder(String readSideId) Create a builder for a JDBC read side event handler.

Method Detail

builder

<Event extends AggregateEvent<Event>> JdbcReadSide.ReadSideHandlerBuilder<Event> builder(String readSideId)

Create a builder for a JDBC read side event handler.

Parameters:

readSideId - An identifier for this read side. This will be used to store offsets in the offset store.

Returns:

The builder.