@Test public void start_invokesRegistration() { EventHubCollector collector = new EventHubCollector(new LazyFuture()); collector.start(); assertThat(registration).isCompleted(); }
@Override public EventHubCollector start() { if (!closed.get()) lazyRegisterEventProcessorFactoryWithHost.get(); return this; }
EventHubCollector extends CollectorComponent { @Override public EventHubCollector start() { if (!closed.get()) lazyRegisterEventProcessorFactoryWithHost.get(); return this; } }
EventHubCollector extends CollectorComponent { @Override public EventHubCollector start() { if (!closed.get()) lazyRegisterEventProcessorFactoryWithHost.get(); return this; } EventHubCollector(Builder builder);   EventHubCollector(
      LazyRegisterEventProcessorFactoryWithHost lazyRegisterEventProcessorFactoryWithHost); }
EventHubCollector extends CollectorComponent { @Override public EventHubCollector start() { if (!closed.get()) lazyRegisterEventProcessorFactoryWithHost.get(); return this; } EventHubCollector(Builder builder);   EventHubCollector(
      LazyRegisterEventProcessorFactoryWithHost lazyRegisterEventProcessorFactoryWithHost); static Builder newBuilder(); @Override EventHubCollector start(); @Override CheckResult check(); @Override void close(); }
EventHubCollector extends CollectorComponent { @Override public EventHubCollector start() { if (!closed.get()) lazyRegisterEventProcessorFactoryWithHost.get(); return this; } EventHubCollector(Builder builder);   EventHubCollector(
      LazyRegisterEventProcessorFactoryWithHost lazyRegisterEventProcessorFactoryWithHost); static Builder newBuilder(); @Override EventHubCollector start(); @Override CheckResult check(); @Override void close();  }