com.lightbend.lagom.javadsl.persistence.cassandra

Interface CassandraReadSide

public interface CassandraReadSide

Cassandra read side support. This should be used to build and register readside

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 java.util.concurrent.CompletionStage<java.util.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 java.util.concurrent.CompletionStage<java.util.List<com.datastax.driver.core.BoundStatement>>	completedStatements() Convenience method to create an already completed CompletionStage with no BoundStatement.
static java.util.concurrent.CompletionStage<java.util.List<com.datastax.driver.core.BoundStatement>>	completedStatements(java.util.List<com.datastax.driver.core.BoundStatement> statements) Convenience method to create an already completed CompletionStage with several BoundStatement.
<Event extends AggregateEvent<Event>> void	register(Class<? extends CassandraReadSideProcessor<Event>> processorClass) Deprecated. Use the builder method to create and register a Cassandra read side processor.

Method Detail

register

@Deprecated
<Event extends AggregateEvent<Event>> void register(Class<? extends CassandraReadSideProcessor<Event>> processorClass)

Deprecated. Use the builder method to create and register a Cassandra read side processor.

At system startup all CassandraReadSideProcessor classes must be registered with this method.

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 java.util.concurrent.CompletionStage<java.util.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 java.util.concurrent.CompletionStage<java.util.List<com.datastax.driver.core.BoundStatement>> completedStatements(java.util.List<com.datastax.driver.core.BoundStatement> statements)

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

completedStatements

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

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