@Test void testNoRevisionForAggregate() { assertFalse(testSubject.test(createEntry(WithoutAnnotationAggregate.class.getName(), "2.3-TEST"))); }
@Override public boolean test(DomainEventData<?> snapshot) { final SerializedType payloadType = snapshot.getPayload().getType(); final String payloadRevision = payloadType.getRevision(); final String aggregateRevision; try { aggregateRevision = resolver.revisionOf(serializer.classForType(payloadType)); } catch (Exception e) { return false; } return Objects.equals(payloadRevision, aggregateRevision); }
EqualRevisionPredicate implements Predicate<DomainEventData<?>> { @Override public boolean test(DomainEventData<?> snapshot) { final SerializedType payloadType = snapshot.getPayload().getType(); final String payloadRevision = payloadType.getRevision(); final String aggregateRevision; try { aggregateRevision = resolver.revisionOf(serializer.classForType(payloadType)); } catch (Exception e) { return false; } return Objects.equals(payloadRevision, aggregateRevision); } }
EqualRevisionPredicate implements Predicate<DomainEventData<?>> { @Override public boolean test(DomainEventData<?> snapshot) { final SerializedType payloadType = snapshot.getPayload().getType(); final String payloadRevision = payloadType.getRevision(); final String aggregateRevision; try { aggregateRevision = resolver.revisionOf(serializer.classForType(payloadType)); } catch (Exception e) { return false; } return Objects.equals(payloadRevision, aggregateRevision); } EqualRevisionPredicate(RevisionResolver resolver, Serializer serializer); }
EqualRevisionPredicate implements Predicate<DomainEventData<?>> { @Override public boolean test(DomainEventData<?> snapshot) { final SerializedType payloadType = snapshot.getPayload().getType(); final String payloadRevision = payloadType.getRevision(); final String aggregateRevision; try { aggregateRevision = resolver.revisionOf(serializer.classForType(payloadType)); } catch (Exception e) { return false; } return Objects.equals(payloadRevision, aggregateRevision); } EqualRevisionPredicate(RevisionResolver resolver, Serializer serializer); @Override boolean test(DomainEventData<?> snapshot); }
EqualRevisionPredicate implements Predicate<DomainEventData<?>> { @Override public boolean test(DomainEventData<?> snapshot) { final SerializedType payloadType = snapshot.getPayload().getType(); final String payloadRevision = payloadType.getRevision(); final String aggregateRevision; try { aggregateRevision = resolver.revisionOf(serializer.classForType(payloadType)); } catch (Exception e) { return false; } return Objects.equals(payloadRevision, aggregateRevision); } EqualRevisionPredicate(RevisionResolver resolver, Serializer serializer); @Override boolean test(DomainEventData<?> snapshot);  }