com.lightbend.lagom.javadsl.persistence.jdbc

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

Enclosing interface:

JdbcReadSide

public static interface JdbcReadSide.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> JdbcReadSide.ReadSideHandlerBuilder<Event>	setEventHandler(Class<E> eventClass, JdbcReadSide.ConnectionBiConsumer<E> handler) Define the event handler that will be used for events of a given class.
<E extends Event> JdbcReadSide.ReadSideHandlerBuilder<Event>	setEventHandler(Class<E> eventClass, JdbcReadSide.ConnectionTriConsumer<E,Offset> handler) Define the event handler that will be used for events of a given class.
JdbcReadSide.ReadSideHandlerBuilder<Event>	setGlobalPrepare(JdbcReadSide.ConnectionConsumer callback) Set a global prepare callback.
JdbcReadSide.ReadSideHandlerBuilder<Event>	setPrepare(JdbcReadSide.ConnectionBiConsumer<AggregateEventTag<Event>> callback) Set a prepare callback.

Method Detail

setGlobalPrepare

JdbcReadSide.ReadSideHandlerBuilder<Event> setGlobalPrepare(JdbcReadSide.ConnectionConsumer callback)

Set a global prepare callback.

Parameters:

callback - The callback.

Returns:

This builder for fluent invocation.

See Also:

ReadSideProcessor.ReadSideHandler.globalPrepare()

setPrepare

JdbcReadSide.ReadSideHandlerBuilder<Event> setPrepare(JdbcReadSide.ConnectionBiConsumer<AggregateEventTag<Event>> 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> JdbcReadSide.ReadSideHandlerBuilder<Event> setEventHandler(Class<E> eventClass,
                                                                             JdbcReadSide.ConnectionBiConsumer<E> 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> JdbcReadSide.ReadSideHandlerBuilder<Event> setEventHandler(Class<E> eventClass,
                                                                             JdbcReadSide.ConnectionTriConsumer<E,Offset> 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.