@DirtiesContext @Test public void testUniqueKeyConstraintOnEventIdentifier() { assertThrows( ConcurrencyException.class, () -> testSubject.appendEvents(createEvent("id", AGGREGATE, 1), createEvent("id", "otherAggregate", 1)) ); }
@Override public void appendEvents(List<? extends EventMessage<?>> events) { appendEvents(events, eventSerializer); }
AbstractEventStorageEngine implements EventStorageEngine { @Override public void appendEvents(List<? extends EventMessage<?>> events) { appendEvents(events, eventSerializer); } }
AbstractEventStorageEngine implements EventStorageEngine { @Override public void appendEvents(List<? extends EventMessage<?>> events) { appendEvents(events, eventSerializer); } protected  AbstractEventStorageEngine(Builder builder); }
AbstractEventStorageEngine implements EventStorageEngine { @Override public void appendEvents(List<? extends EventMessage<?>> events) { appendEvents(events, eventSerializer); } protected  AbstractEventStorageEngine(Builder builder); @Override Stream<? extends TrackedEventMessage<?>> readEvents(TrackingToken trackingToken, boolean mayBlock); @Override DomainEventStream readEvents(String aggregateIdentifier, long firstSequenceNumber); @Override Optional<DomainEventMessage<?>> readSnapshot(String aggregateIdentifier); @Override void appendEvents(List<? extends EventMessage<?>> events); @Override void storeSnapshot(DomainEventMessage<?> snapshot); Serializer getSnapshotSerializer(); Serializer getEventSerializer(); }
AbstractEventStorageEngine implements EventStorageEngine { @Override public void appendEvents(List<? extends EventMessage<?>> events) { appendEvents(events, eventSerializer); } protected  AbstractEventStorageEngine(Builder builder); @Override Stream<? extends TrackedEventMessage<?>> readEvents(TrackingToken trackingToken, boolean mayBlock); @Override DomainEventStream readEvents(String aggregateIdentifier, long firstSequenceNumber); @Override Optional<DomainEventMessage<?>> readSnapshot(String aggregateIdentifier); @Override void appendEvents(List<? extends EventMessage<?>> events); @Override void storeSnapshot(DomainEventMessage<?> snapshot); Serializer getSnapshotSerializer(); Serializer getEventSerializer();  }