Spring Rabbit: Intercept-Methodenaufrufe mit @RabbitListener ohne AspectJ-Verwendung kommentiert

Question

Gibt es eine Möglichkeit zum Abfangen von Aufrufen von Bean-Methoden, die mit @RabbitListener kommentiert wurden, ohne AspectJ zu verwenden.

Der Code ist so etwas wie dieses

@OtherAnnotation 
@RabbitListener 
public void do(Message message) 

Ich brauche alle Anrufe @RabbitListener Methode abfangen, wenn die Methode @OtherAnnotation Annotation hat.

UPDATE:

Ich konnte es Lösung mit Gary Russell zu arbeiten.

public class CustomRabbitListenerAnnotationBeanPostProcessor extends RabbitListenerAnnotationBeanPostProcessor { 

    @Override 
    protected void processAmqpListener(RabbitListener rabbitListener, final Method method, Object bean, String beanName) { 
     if (method.isAnnotationPresent(OtherAnnotation.class)) { 
      ProxyFactory proxyFactory = new ProxyFactory(bean); 
      proxyFactory.addAdvisor(new StaticMethodMatcherPointcutAdvisor(new OtherAnnotationInterceptor()) { 
       @Override 
       public boolean matches(Method advisorMethod, Class<?> targetClass) { 
        return advisorMethod.equals(method); 
       } 
      }); 
      Object proxiedBean = proxyFactory.getProxy(); 
      super.processAmqpListener(rabbitListener, method, proxiedBean, beanName); 
     } else { 
      super.processAmqpListener(rabbitListener, method, bean, beanName); 
     } 
    } 
} 

Die Bohne Definition ist wie:

@Bean(name = RabbitListenerConfigUtils.RABBIT_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME) 
    public CustomRabbitListenerAnnotationBeanPostProcessor customRabbitListenerAnnotationBeanPostProcessor() { 
     return new CustomRabbitListenerAnnotationBeanPostProcessor(); 
    } 

Es ist ein bisschen hässlich, aber es funktioniert. Wenn jemand eine bessere Lösung hat, teilen Sie es bitte mit.

Answer 1

experimentieren können Sie RabbitListenerAnnotationBeanPostProcessor Unterklasse und überschreiben die processListener Methode und ändern Sie die Bean, bevor Sie die Super-Version aufrufen.

Dann ersetzen Sie die RabbitListenerConfigUtils.RABBIT_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME Bean von der @EnableRabbit mit Ihrer Unterklasse registriert.

Oder geben Sie einfach Ihre Ratschläge an die Beratungsstelle der Containerfabrik und alle Zuhörer werden benachrichtigt. Sie können dann eine Laufzeitprüfung durchführen, um festzustellen, ob die andere Anmerkung vorhanden ist.

Answer 2

denke ich, was Sie suchen für ein bean-post-processor

ist

herer ein einfaches Beispiel: https://www.tutorialspoint.com/spring/spring_bean_post_processors.htm

, wenn Sie Anrufe müssen abfangen Sie einen Proxy über die zurückgegebene Instanz wickeln können. Ein gutes Beispiel ist org.springframework.validation.beanvalidation.MethodValidationPostProcessor. Sie können wahrscheinlich auch org.springframework.aop.framework.AbstractAdvisingBeanPostProcessor erweitern.

---

EDIT ich lerne mich gerade dies so hoffe ich, dass der richtige Weg, dies zu tun, aber das ist für mich gearbeitet, wenn sie mit ihm

@Component 
public class MyInterceptAnnotationBeanPostProcessor 
    extends AbstractBeanFactoryAwareAdvisingPostProcessor 
    implements InitializingBean { 

    public void afterPropertiesSet() { 
     AnnotationMatchingPointcut pointcut = new AnnotationMatchingPointcut(
       null, 
       MyIntercept.class); 
     this.advisor = new DefaultPointcutAdvisor(pointcut, this.createAdvice()); 
    } 

    protected Advice createAdvice() { 
     return new MethodInterceptor() { 

      @Override 
      public Object invoke(MethodInvocation arg0) throws Throwable { 
       System.out.println("advice"); 
       return arg0.proceed(); 
      } 
     }; 
    } 
}