BackupReplyProcessor extends AdminMultipleReplyProcessor { @Override protected void process(DistributionMessage message, boolean warn) { if (message instanceof BackupResponse) { BackupResponse response = (BackupResponse) message; resultCollector.addToResults(response.getSender(), response.getPersistentIds()); } super.process(message, warn); } BackupReplyProcessor(BackupResultCollector resultCollector, DistributionManager dm,
      Set<InternalDistributedMember> recipients); @Override long getAckSevereAlertThresholdMS();  }
@Test public void processBackupResponseAddsSenderToResults() throws Exception { backupReplyProcessor.process(backupResponse, false); verify(resultCollector, times(1)).addToResults(eq(sender), eq(persistentIds)); }
@Test public void processNonBackupResponseDoesNotAddSenderToResults() throws Exception { backupReplyProcessor.process(nonBackupResponse, false); verify(resultCollector, times(0)).addToResults(eq(sender), eq(persistentIds)); }