@Test public void shouldMarkFail() { compositeRepository.markFail("opId"); verify(eventRecorder).markFail("opId"); }
@Override public List<EntityEvent> markFail(String opId) { return eventRecorder.markFail(opId); }
CompositeRepositoryImpl implements EventRepository { @Override public List<EntityEvent> markFail(String opId) { return eventRecorder.markFail(opId); } }
CompositeRepositoryImpl implements EventRepository { @Override public List<EntityEvent> markFail(String opId) { return eventRecorder.markFail(opId); } CompositeRepositoryImpl(EventRecorder eventRecorder, ObjectMapper objectMapper,
                                   IOperationRepository operationRepository); }
CompositeRepositoryImpl implements EventRepository { @Override public List<EntityEvent> markFail(String opId) { return eventRecorder.markFail(opId); } CompositeRepositoryImpl(EventRecorder eventRecorder, ObjectMapper objectMapper,
                                   IOperationRepository operationRepository); @Override List<EntityEvent> markFail(String opId); @Override EventKey recordAndPublish(P publishedEvent); @Override EventKey recordAndPublish(Entity previousEntity, P publishedEvent); @Override EventKey recordAndPublish(EventKey previousEventKey, P publishedEvent); @Override EventKey recordAndPublish(
            Entity previousEntity, P publishedEvent, Function<EntityEvent, ConcurrencyResolver<T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            EventKey eventKey, P publishedEvent, Function<EntityEvent, ConcurrencyResolver<T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            Entity entity, P publishedEvent, Supplier<ConcurrentEventResolver<P, T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            EventKey previousEventKey, P publishedEvent, Supplier<ConcurrentEventResolver<P, T>> concurrencyResolverFactory
    ); @Override EventRecorder getEventRecorder(); }
CompositeRepositoryImpl implements EventRepository { @Override public List<EntityEvent> markFail(String opId) { return eventRecorder.markFail(opId); } CompositeRepositoryImpl(EventRecorder eventRecorder, ObjectMapper objectMapper,
                                   IOperationRepository operationRepository); @Override List<EntityEvent> markFail(String opId); @Override EventKey recordAndPublish(P publishedEvent); @Override EventKey recordAndPublish(Entity previousEntity, P publishedEvent); @Override EventKey recordAndPublish(EventKey previousEventKey, P publishedEvent); @Override EventKey recordAndPublish(
            Entity previousEntity, P publishedEvent, Function<EntityEvent, ConcurrencyResolver<T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            EventKey eventKey, P publishedEvent, Function<EntityEvent, ConcurrencyResolver<T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            Entity entity, P publishedEvent, Supplier<ConcurrentEventResolver<P, T>> concurrencyResolverFactory
    ); @Override EventKey recordAndPublish(
            EventKey previousEventKey, P publishedEvent, Supplier<ConcurrentEventResolver<P, T>> concurrencyResolverFactory
    ); @Override EventRecorder getEventRecorder();  }