Observer method processing
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)); | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment