Observer method processing

part11-4.java

private final void processObserverMethod(@Observes final ProcessObserverMethod<? extends org.microbean.kubernetes.controller.Event<? extends HasMetadata>, ?> event, final BeanManager beanManager) {
  if (event != null) {
    this.processPotentialEventSelectorObserverMethod(event.getObserverMethod(), beanManager);
  }
}

private final void processSyntheticObserverMethod(@Observes final ProcessSyntheticObserverMethod<? extends org.microbean.kubernetes.controller.Event<? extends HasMetadata>, ?> event, final BeanManager beanManager) {
  if (event != null) {
    this.processPotentialEventSelectorObserverMethod(event.getObserverMethod(), beanManager);
  }
}

private final void processPotentialEventSelectorObserverMethod(final ObserverMethod<? extends org.microbean.kubernetes.controller.Event<? extends HasMetadata>> observerMethod, final BeanManager beanManager) {
  if (observerMethod != null) {
    final Set<Annotation> kubernetesEventSelectors = Annotations.retainAnnotationsQualifiedWith(observerMethod.getObservedQualifiers(), KubernetesEventSelector.class, beanManager);
    if (kubernetesEventSelectors != null && !kubernetesEventSelectors.isEmpty()) {
      if (observerMethod.isAsync()) {
        if (!this.asyncNeeded) {
          this.asyncNeeded = true;
        }
      } else if (!this.syncNeeded) {
        this.syncNeeded = true;
      }
      this.beans.add(this.eventSelectorBeans.remove(kubernetesEventSelectors));
    }
  }
}