Package org.springframework.cloud.stream.binding

Class StreamListenerAnnotationBeanPostProcessor

java.lang.Object
org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware
public class StreamListenerAnnotationBeanPostProcessor extends Object implements org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.SmartInitializingSingleton
BeanPostProcessor that handles StreamListener annotations found on bean methods.
Author:
Marius Bogoevici, Ilayaperumal Gopinathan, Soby Chacko, Oleg Zhurakousky

  • Constructor Details

    • StreamListenerAnnotationBeanPostProcessor

      public StreamListenerAnnotationBeanPostProcessor()

  • Method Details

    • setApplicationContext

      public final void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
      Specified by:
      setApplicationContext in interface org.springframework.context.ApplicationContextAware
      Throws:
      org.springframework.beans.BeansException

    • afterSingletonsInstantiated

      public final void afterSingletonsInstantiated()
      Specified by:
      afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingleton

    • postProcessAfterInitialization

      public final Object postProcessAfterInitialization(Object bean, String beanName) throws org.springframework.beans.BeansException
      Specified by:
      postProcessAfterInitialization in interface org.springframework.beans.factory.config.BeanPostProcessor
      Throws:
      org.springframework.beans.BeansException

    • postProcessAnnotation

      protected StreamListener postProcessAnnotation(StreamListener originalAnnotation, Method annotatedMethod)
      Extension point, allowing subclasses to customize the StreamListener annotation detected by the postprocessor.
      Parameters:
      originalAnnotation - the original annotation
      annotatedMethod - the method on which the annotation has been found
      Returns:
      the postprocessed StreamListener annotation