StepManager extends Observable implements MessageListener { public void closeConnections() { JmsUtils.closeQuietly(session); JmsUtils.closeQuietly(consumer); JmsUtils.closeQuietly(sender); } StepManager(TimeoutWatch timeoutWatch, JmsConnection jmsConnection, String correlationId,
      long messageTimeToLive); void closeConnections(); int getTotalTasksCount(); ProgressLog getProgress();  }
@Test public void closeConnections() throws Exception { tested.closeConnections(); verify(session, times(1)).close(); verify(consumer, times(1)).close(); verify(sender, times(1)).close(); }