ManagedNSQConsumer implements Managed { @Override public void stop() throws Exception { flowableNSQConsumer.shutdown(); } ManagedNSQConsumer(FlowableNSQConsumer<?> flowableNSQConsumer); @Override void start(); @Override void stop();  }
@Test public void should_shutdown_flowable_when_managed_consumer_is_stopped() throws Exception { managedNSQConsumer.stop(); verify(flowable).shutdown(); }