Package com.opencqrs.framework.persistence

Class EventRepository

java.lang.Object

com.opencqrs.framework.persistence.EventRepository

All Implemented Interfaces:

EventReader, ImmediateEventPublisher

public class EventRepository
extends Object
implements EventReader, ImmediateEventPublisher

Default implementation of EventReader and ImmediateEventPublisher.

Nested Class Summary

Nested classes/interfaces inherited from interface com.opencqrs.framework.persistence.EventReader

EventReader.ClientRequestor, EventReader.RawCallback, EventReader.UpcastedCallback

Constructor Summary

Constructors

Constructor	Description
EventRepository(EsdbClient client, EventSource eventSource, EventTypeResolver eventTypeResolver, EventDataMarshaller eventDataMarshaller, EventUpcasters eventUpcasters)

Method Summary

Modifier and Type	Method	Description
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.
List<Event>	publish(Consumer<EventPublisher> handler, List<Precondition> additionalPreconditions)	Atomically publishes all events captured from the given EventPublisher consumer together with the additional preconditions.
List<Event>	publish(List<CapturedEvent> events, List<Precondition> additionalPreconditions)	Atomically publishes the given events together with the additional preconditions.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.opencqrs.framework.persistence.EventReader

consumeAsObject, consumeAsObject, consumeUpcasted, readAsObject, readRaw, readUpcasted

Methods inherited from interface com.opencqrs.framework.persistence.ImmediateEventPublisher

publish, publish, publish

Constructor Details

EventRepository

public EventRepository(EsdbClient client,
 EventSource eventSource,
 EventTypeResolver eventTypeResolver,
 EventDataMarshaller eventDataMarshaller,
 EventUpcasters eventUpcasters)

Method Details

consumeRaw

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

Description copied from interface: EventReader

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

Specified by:

consumeRaw in interface EventReader

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

publish

public List<Event> publish(Consumer<EventPublisher> handler,
 List<Precondition> additionalPreconditions)

Description copied from interface: ImmediateEventPublisher

Atomically publishes all events captured from the given EventPublisher consumer together with the additional preconditions.

Specified by:

publish in interface ImmediateEventPublisher

Parameters:

handler - callback capturing all events to be published atomically

additionalPreconditions - additional preconditions that must not be violated

Returns:

the list of published Events

publish

public List<Event> publish(List<CapturedEvent> events,
 List<Precondition> additionalPreconditions)

Description copied from interface: ImmediateEventPublisher

Atomically publishes the given events together with the additional preconditions.

Specified by:

publish in interface ImmediateEventPublisher

Parameters:

events - a list of captured events to be published atomically

additionalPreconditions - additional preconditions that must not be violated

Returns:

the list of published Events