public void close() {
    commandConsumer.close();
    commandTopicBackup.close();
  }
@Test
  public void shouldCloseCommandTopicBackup() {
    // When
    commandTopic.close();

    // Then
    verify(commandTopicBackup, times(1)).close();
  }