com.lightbend.lagom.javadsl.persistence.cassandra

Interface CassandraReadSide

public interface CassandraReadSide

Cassandra read side support.

This should be used to build and register a read side processor.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	CassandraReadSide.ReadSideHandlerBuilder<Event extends AggregateEvent<Event>> Builder for the handler.

Method Summary

Modifier and Type	Method and Description
<Event extends AggregateEvent<Event>> CassandraReadSide.ReadSideHandlerBuilder<Event>	builder(String readSideId) Create a builder for a Cassandra read side event handler.
static CompletionStage<List<com.datastax.driver.core.BoundStatement>>	completedStatement(com.datastax.driver.core.BoundStatement statement) Convenience method to create an already completed CompletionStage with one BoundStatement.
static CompletionStage<List<com.datastax.driver.core.BoundStatement>>	completedStatements() Convenience method to create an already completed CompletionStage with no BoundStatement.
static CompletionStage<List<com.datastax.driver.core.BoundStatement>>	completedStatements(com.datastax.driver.core.BoundStatement... statements) Convenience method to create an already completed CompletionStage with several BoundStatement.
static CompletionStage<List<com.datastax.driver.core.BoundStatement>>	completedStatements(List<com.datastax.driver.core.BoundStatement> statements) Convenience method to create an already completed CompletionStage with several BoundStatement.

Method Detail

builder

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

Create a builder for a Cassandra 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.

completedStatement

static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatement(com.datastax.driver.core.BoundStatement statement)

Convenience method to create an already completed CompletionStage with one BoundStatement.

completedStatements

static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements(List<com.datastax.driver.core.BoundStatement> statements)

Convenience method to create an already completed CompletionStage with several BoundStatement.

completedStatements

static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements(com.datastax.driver.core.BoundStatement... statements)

Convenience method to create an already completed CompletionStage with several BoundStatement.

completedStatements

static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements()

Convenience method to create an already completed CompletionStage with no BoundStatement.