com.lightbend.lagom.javadsl.persistence.cassandra

Interface CassandraReadSide.ReadSideHandlerBuilder<Event extends AggregateEvent<Event>>

Enclosing interface:

CassandraReadSide

public static interface CassandraReadSide.ReadSideHandlerBuilder<Event extends AggregateEvent<Event>>

Builder for the handler.

Method Summary

Modifier and Type	Method and Description
ReadSideProcessor.ReadSideHandler<Event>	build() Build the read side handler.
<E extends Event> CassandraReadSide.ReadSideHandlerBuilder<Event>	setEventHandler(Class<E> eventClass, BiFunction<E,Offset,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler) Define the event handler that will be used for events of a given class.
<E extends Event> CassandraReadSide.ReadSideHandlerBuilder<Event>	setEventHandler(Class<E> eventClass, Function<E,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler) Define the event handler that will be used for events of a given class.
CassandraReadSide.ReadSideHandlerBuilder<Event>	setGlobalPrepare(Supplier<CompletionStage<akka.Done>> callback) Set a global prepare callback.
CassandraReadSide.ReadSideHandlerBuilder<Event>	setPrepare(Function<AggregateEventTag<Event>,CompletionStage<akka.Done>> callback) Set a prepare callback.

Method Detail

setGlobalPrepare

CassandraReadSide.ReadSideHandlerBuilder<Event> setGlobalPrepare(Supplier<CompletionStage<akka.Done>> callback)

Set a global prepare callback.

Parameters:

callback - The callback.

Returns:

This builder for fluent invocation.

See Also:

ReadSideProcessor.ReadSideHandler.globalPrepare()

setPrepare

CassandraReadSide.ReadSideHandlerBuilder<Event> setPrepare(Function<AggregateEventTag<Event>,CompletionStage<akka.Done>> callback)

Set a prepare callback.

Parameters:

callback - The callback.

Returns:

This builder for fluent invocation.

See Also:

ReadSideProcessor.ReadSideHandler.prepare(AggregateEventTag)

setEventHandler

<E extends Event> CassandraReadSide.ReadSideHandlerBuilder<Event> setEventHandler(Class<E> eventClass,
                                                                                  Function<E,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler)

Define the event handler that will be used for events of a given class.

Parameters:

eventClass - The event class to handle.

handler - The function to handle the events.

Returns:

This builder for fluent invocation

setEventHandler

<E extends Event> CassandraReadSide.ReadSideHandlerBuilder<Event> setEventHandler(Class<E> eventClass,
                                                                                  BiFunction<E,Offset,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler)

Define the event handler that will be used for events of a given class. This variant allows for offsets to be consumed as well as their events.

Parameters:

eventClass - The event class to handle.

handler - The function to handle the events.

Returns:

This builder for fluent invocation

build

ReadSideProcessor.ReadSideHandler<Event> build()

Build the read side handler.

Returns:

The read side handler.