part11-9.java

private final <T extends HasMetadata, X extends Listable<? extends KubernetesResourceList> & VersionWatchable<? extends Closeable, Watcher<T>>> void startControllers(@Observes @Initialized(ApplicationScoped.class) @Priority(LIBRARY_AFTER) final Object ignored, final BeanManager beanManager) { 
  if (beanManager != null) {
    for (final Bean<?> bean : this.beans) {
      assert bean != null;
          
      final Set<Annotation> qualifiers = bean.getQualifiers();

      final Map<Object, T> knownObjects = new HashMap<>();
          
      final EventDistributor<T> eventDistributor = new EventDistributor<>(knownObjects);
      eventDistributor.addConsumer(new CDIEventDistributor<T>(qualifiers, null /* no NotificationOptions; TODO */, this.syncNeeded, this.asyncNeeded));

      @SuppressWarnings("unchecked") // we know an Operation is of type X
      final X contextualReference = (X)beanManager.getReference(bean, getOperationType(bean), beanManager.createCreationalContext(bean));
          
      final Controller<T> controller = new Controller<>(contextualReference, knownObjects, eventDistributor);
      controller.start();
      this.controllers.add(controller);
    }
  }
}