public interface CassandraReadSide
Modifier and Type | Interface and Description |
---|---|
static interface |
CassandraReadSide.ReadSideHandlerBuilder<Event extends AggregateEvent<Event>>
Builder for the handler.
|
Modifier and Type | Method and Description |
---|---|
<Event extends AggregateEvent<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 . |
<Event extends AggregateEvent<Event>> |
register(Class<? extends CassandraReadSideProcessor<Event>> processorClass)
Deprecated.
Use the builder method to create and register a Cassandra read side processor.
|
@Deprecated <Event extends AggregateEvent<Event>> void register(Class<? extends CassandraReadSideProcessor<Event>> processorClass)
CassandraReadSideProcessor
classes must be registered
with this method.<Event extends AggregateEvent<Event>> CassandraReadSide.ReadSideHandlerBuilder<Event> builder(String readSideId)
readSideId
- An identifier for this read side. This will be used to store offsets in the offset store.static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatement(com.datastax.driver.core.BoundStatement statement)
CompletionStage
with one BoundStatement
.static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements(List<com.datastax.driver.core.BoundStatement> statements)
CompletionStage
with several BoundStatement
.static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements(com.datastax.driver.core.BoundStatement... statements)
CompletionStage
with several BoundStatement
.static CompletionStage<List<com.datastax.driver.core.BoundStatement>> completedStatements()
CompletionStage
with no BoundStatement
.