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

    //Then:
    verify(commandConsumer).close();
  }