@Test void willGetReplayStatus() { Map<String, Object> status = replayEndpoint.status(); assertEquals(Map.of("ReplayableEventProcessors", 1, "currentlyReplaying", 0, "isReplaying", false), status); }
@ReadOperation public Map<String, Object> status() { var statusMap = new HashMap<String, Object>(); statusMap.put("ReplayableEventProcessors", getReplayableEventProcessors().size()); int currentlyReplaying = replayingProcessors.size(); statusMap.put("currentlyReplaying", currentlyReplaying); statusMap.put("isReplaying", currentlyReplaying > 0); return statusMap; }
ReplayEndpoint { @ReadOperation public Map<String, Object> status() { var statusMap = new HashMap<String, Object>(); statusMap.put("ReplayableEventProcessors", getReplayableEventProcessors().size()); int currentlyReplaying = replayingProcessors.size(); statusMap.put("currentlyReplaying", currentlyReplaying); statusMap.put("isReplaying", currentlyReplaying > 0); return statusMap; } }
ReplayEndpoint { @ReadOperation public Map<String, Object> status() { var statusMap = new HashMap<String, Object>(); statusMap.put("ReplayableEventProcessors", getReplayableEventProcessors().size()); int currentlyReplaying = replayingProcessors.size(); statusMap.put("currentlyReplaying", currentlyReplaying); statusMap.put("isReplaying", currentlyReplaying > 0); return statusMap; } @Autowired  ReplayEndpoint(AxonConfiguration axonConfiguration,
                          List<ReplayCompletionAware> replayCompletionAwares,
                          TaskExecutor taskExecutor); }
ReplayEndpoint { @ReadOperation public Map<String, Object> status() { var statusMap = new HashMap<String, Object>(); statusMap.put("ReplayableEventProcessors", getReplayableEventProcessors().size()); int currentlyReplaying = replayingProcessors.size(); statusMap.put("currentlyReplaying", currentlyReplaying); statusMap.put("isReplaying", currentlyReplaying > 0); return statusMap; } @Autowired  ReplayEndpoint(AxonConfiguration axonConfiguration,
                          List<ReplayCompletionAware> replayCompletionAwares,
                          TaskExecutor taskExecutor); @ReadOperation Map<String, Object> status(); @WriteOperation void startReplay(@Nullable Set<String> processingGroups,
                            @Nullable OffsetDateTime startTime); }
ReplayEndpoint { @ReadOperation public Map<String, Object> status() { var statusMap = new HashMap<String, Object>(); statusMap.put("ReplayableEventProcessors", getReplayableEventProcessors().size()); int currentlyReplaying = replayingProcessors.size(); statusMap.put("currentlyReplaying", currentlyReplaying); statusMap.put("isReplaying", currentlyReplaying > 0); return statusMap; } @Autowired  ReplayEndpoint(AxonConfiguration axonConfiguration,
                          List<ReplayCompletionAware> replayCompletionAwares,
                          TaskExecutor taskExecutor); @ReadOperation Map<String, Object> status(); @WriteOperation void startReplay(@Nullable Set<String> processingGroups,
                            @Nullable OffsetDateTime startTime);  }