Проблема, связанная с Spring-AOP: JoinPointMatch НЕ был связан при вызове

У меня есть проект springboot + spring cloud streams, там у меня настроены несколько прослушивателей потоков, и я хочу добиться перехвата каждого входящего сообщения, чтобы извлечь из него заголовок и что-то сделать с его значением до того, как сообщение будет фактически обработанный. Для этого я создал совет АОП следующим образом:

@Aspect
@Component
@Order(Ordered.HIGHEST_PRECEDENCE)
public class StreamDyeContextPropagator {

    @Pointcut(value = "@annotation(listener) && execution(* com.mycompany.subpackage..*(org.springframework.messaging.Message+)) && args(message)", argNames = "listener, message")
    public void streamListener(StreamListener listener, Message<?> message) {
    }

    @Around(value = "streamListener(listener, message)", argNames = "pjp, listener, message")
    public Object retrieveDye(final ProceedingJoinPoint pjp, StreamListener listener, Message<?> message) throws Throwable {
        // Some logic here
    }
}

Ниже приведен код прослушивателя весенних облачных потоков:

@EnableBinding(ExchangeRateSink.class)
public class ExchangeRateFromStreamListener {

    @Loggable
    @StreamListener(ExchangeRateSink.NEWEXCHANGERATE)
    public void handle(Message<NewExchangeRateMessage> message) {
        // Some logic here
    }

Но когда я запускаю проект, я получаю следующее исключение:

Caused by: java.lang.IllegalStateException: Required to bind 3 arguments, but only bound 1 (JoinPointMatch was NOT bound in invocation) at org.springframework.aop.aspectj.AbstractAspectJAdvice.argBinding(AbstractAspectJAdvice.java:605) ...

Любая помощь, пожалуйста?

PS: я знаю, что могу использовать @GlobalChannelInterceptor, чтобы сделать что-то подобное, но я хочу сделать это через АОП, и я хочу знать, что здесь происходит. Заранее спасибо!