public long append(final Stream<JsonEnvelope> events) throws EventStreamException {
final long currentVersion = super.append(events);
createAggregateSnapshotsFor(currentVersion);
return currentVersion;
}
<BUG>@Override
public long appendAfter(final Stream<JsonEnvelope> events, final long version) throws EventStreamException {</BUG>
final long currentVersion = super.appendAfter(events, version);
createAggregateSnapshotsFor(currentVersion);
return currentVersion;

public long append(final Stream<JsonEnvelope> events) throws EventStreamException {
final long currentVersion = super.append(events);
createAggregateSnapshotsFor(currentVersion);
return currentVersion;
