snapshotLiquidBase.update("");
}
private Stream<JsonEnvelope> envelopes(final int numberOfEnvelopes, String eventName) {
List<JsonEnvelope> envelopes = new LinkedList<>();
for (int i = 1; i <= numberOfEnvelopes; i++) {
<BUG>envelopes.add(envelope().with(metadataWithRandomUUID(eventName).withStreamId(STREAM_ID)).withPayloadOf("value", "name").build());
}</BUG>
return envelopes.stream();
}
public static class DummyJmsEventPublisher implements EventPublisher {

snapshotLiquidBase.update("");
}
private Stream<JsonEnvelope> envelopes(final int numberOfEnvelopes, String eventName) {
List<JsonEnvelope> envelopes = new LinkedList<>();
for (int i = 1; i <= numberOfEnvelopes; i++) {
envelopes.add(envelope()
.with(metadataWithRandomUUID(eventName)
.createdAt(clock.now())
.withStreamId(STREAM_ID))
.withPayloadOf("value", "name").build());
}
return envelopes.stream();
}
public static class DummyJmsEventPublisher implements EventPublisher {
