Package com.opencqrs.framework.persistence

Interface EventReader

All Known Implementing Classes:

EventRepository

public interface EventReader

Interface specifying operations for reading events from an EsdbClient. This includes reading raw Events, upcasted Events, or events converted to Java Objects and meta-data.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	EventReader.ClientRequestor	Generically wraps EsdbClient calls to consume Events.
static interface	EventReader.RawCallback	Callback interface specifying operations to deal with an encapsulated raw Event.
static interface	EventReader.UpcastedCallback	Callback interface specifying operations to deal with an encapsulated upcasted Event.

Method Summary

Modifier and Type	Method	Description
default void	consumeAsObject(EventReader.ClientRequestor clientRequestor, BiConsumer<Map<String,?>,Object> eventConsumer)	Consumes upcasted and converted meta-data and Java event objects from the given EventReader.ClientRequestor and passes them to the given event consumer.
default void	consumeAsObject(EventReader.ClientRequestor clientRequestor, Consumer<Object> eventConsumer)	Consumes upcasted and converted Java event objects from the given EventReader.ClientRequestor and passes them to the given event consumer.
void	consumeRaw(EventReader.ClientRequestor clientRequestor, BiConsumer<EventReader.RawCallback,Event> eventConsumer)	Consumes raw Events from the given EventReader.ClientRequestor and passes them to the given event consumer.
default void	consumeUpcasted(EventReader.ClientRequestor clientRequestor, BiConsumer<EventReader.UpcastedCallback,Event> eventConsumer)	Consumes upcasted Events from the given EventReader.ClientRequestor and passes them to the given event consumer.
default List<Object>	readAsObject(String subject, Set<Option> options)	Retrieves a list of upcasted and converted Java event objects matching the given subject and options.
default List<Event>	readRaw(String subject, Set<Option> options)	Retrieves a list of raw Events matching the given subject and options.
default List<Event>	readUpcasted(String subject, Set<Option> options)	Retrieves a list of upcasted Events matching the given subject and options.

Method Details

consumeRaw

void consumeRaw(EventReader.ClientRequestor clientRequestor,
 BiConsumer<EventReader.RawCallback,Event> eventConsumer)

Consumes raw Events from the given EventReader.ClientRequestor and passes them to the given event consumer.

Parameters:

clientRequestor - wrapping the client fetch operation

eventConsumer - a bi-consumer called for each raw Event accompanied by a EventReader.RawCallback for futher event processing, if needed

consumeUpcasted

default void consumeUpcasted(EventReader.ClientRequestor clientRequestor,
 BiConsumer<EventReader.UpcastedCallback,Event> eventConsumer)

Consumes upcasted Events from the given EventReader.ClientRequestor and passes them to the given event consumer.

Parameters:

clientRequestor - wrapping the client fetch operation

eventConsumer - a bi-consumer called for each upcasted Event accompanied by an EventReader.UpcastedCallback for further event processing, if needed

See Also:

• EventUpcasters

consumeAsObject

default void consumeAsObject(EventReader.ClientRequestor clientRequestor,
 Consumer<Object> eventConsumer)

Consumes upcasted and converted Java event objects from the given EventReader.ClientRequestor and passes them to the given event consumer.

Parameters:

clientRequestor - wrapping the client fetch operation

eventConsumer - a consumer called for each upcasted and converted Java event object

See Also:

• EventUpcasters
• EventTypeResolver
• EventDataMarshaller

consumeAsObject

default void consumeAsObject(EventReader.ClientRequestor clientRequestor,
 BiConsumer<Map<String,?>,Object> eventConsumer)

Consumes upcasted and converted meta-data and Java event objects from the given EventReader.ClientRequestor and passes them to the given event consumer.

Parameters:

clientRequestor - wrapping the client fetch operation

eventConsumer - a bi-consumer called for each upcasted and converted meta-data and Java event object

See Also:

• EventUpcasters
• EventTypeResolver
• EventDataMarshaller

readRaw

default List<Event> readRaw(String subject,
 Set<Option> options)

Retrieves a list of raw Events matching the given subject and options.

Parameters:

subject - the subject to fetch from

options - set of fetch options

Returns:

a list of raw Events, may be empty

readUpcasted

default List<Event> readUpcasted(String subject,
 Set<Option> options)

Retrieves a list of upcasted Events matching the given subject and options.

Parameters:

subject - the subject to fetch from

options - set of fetch options

Returns:

a list of upcasted Events, may be empty

readAsObject

default List<Object> readAsObject(String subject,
 Set<Option> options)

Retrieves a list of upcasted and converted Java event objects matching the given subject and options.

Parameters:

subject - the subject to fetch from

options - set of fetch options

Returns:

a list of Java event objects, may be empty