com.lightbend.lagom.javadsl.persistence.cassandra

Class CassandraReadSideProcessor.EventHandlersBuilder

Object

com.lightbend.lagom.javadsl.persistence.cassandra.CassandraReadSideProcessor.EventHandlersBuilder

Enclosing class:

CassandraReadSideProcessor<Event extends AggregateEvent<Event>>

public class CassandraReadSideProcessor.EventHandlersBuilder
extends Object

Mutable builder for defining event handlers.

Constructor Summary

Constructors

Constructor and Description
EventHandlersBuilder()

Method Summary

Modifier and Type	Method and Description
CassandraReadSideProcessor.EventHandlers	build() When all event handlers have been defined the immutable ReadSideHandler is created with this method.
<E extends Event> void	setEventHandler(Class<E> eventClass, BiFunction<E,UUID,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler) Define the event handler that will be used for events of a given class.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventHandlersBuilder

public EventHandlersBuilder()

Method Detail

build

public CassandraReadSideProcessor.EventHandlers build()

When all event handlers have been defined the immutable ReadSideHandler is created with this method.

setEventHandler

public <E extends Event> void setEventHandler(Class<E> eventClass,
                                              BiFunction<E,UUID,CompletionStage<List<com.datastax.driver.core.BoundStatement>>> handler)

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