대상 메소드 주변에서 실행되는 AOP 조언을 추가한 후 Spring 클라우드 스트림 테스트 실패

입력 채널에서 이벤트를 소비하는 스트림 리스너가 있는 스프링 클라우드 스트림 애플리케이션이 있습니다. 처리 방법의 실행을 기록하기 위해 AOP 조언을 추가할 때까지 모든 것이 원활하게 실행됩니다(응용 프로그램의 다른 사람 간에). 그 후 다음 오류와 함께 테스트가 실패하기 시작했습니다.

org.springframework.messaging.MessagingException: com.acme.fx.exchangerate.store.infrastructure.entrypoint.messaging.ExchangeRateStoreStreamListener$$EnhancerBySpringCGLIB$$9795881e#handle[1 args]를 호출하는 동안 예외가 발생했습니다. 중첩 예외는 java.lang.IllegalStateException입니다. 매핑된 처리기 메서드 클래스 'com.acme.fx.exchangerate.store.infrastructure.entrypoint.messaging.ExchangeRateStoreStreamListener$$EnhancerBySpringCGLIB$$9795881e$MockitoMock$1733324661'이 실제 끝점의 인스턴스가 아닙니다. 빈 클래스 'com.acme.fx.exchangerate.store.infrastructure.entrypoint.messaging.ExchangeRateStoreStreamListener$$EnhancerBySpringCGLIB$$9795881e$$EnhancerBySpringCGLIB$$2a2d55ce'. 엔드포인트에 프록시가 필요한 경우(예: @Transactional로 인해) 클래스 기반 프록시를 사용하세요. HandlerMethod 세부 정보: ...

싱크 정의:

애플리케이션 코드는 다음과 같습니다.

public interface ExchangeRateStoreStreamSink {
        String NEWEXCHANGERATE="new-exchange-rate";

        @Input(NEWEXCHANGERATE)
        SubscribableChannel newExchangeRate();
}

주석이 달린 메서드가 있는 스트림 리스너:

@EnableBinding(ExchangeRateStoreStreamSink.class)
public class ExchangeRateStoreStreamListener {
    private CommandBus commandBus;

    @Autowired
    public ExchangeRateStoreStreamListener(CommandBus commandBus) {
        this.commandBus = commandBus;
    }

    @Loggable(operationName="ExchangeRateConsumption")
    @StreamListener(ExchangeRateStoreStreamSink.NEWEXCHANGERATE)
    public void handle(NewExchangeRateMessage newExchangeRateMessage) {
        AddExchangeRateCommand addExchangeRateCommand = new AddExchangeRateCommand(newExchangeRateMessage.from,
                newExchangeRateMessage.to, newExchangeRateMessage.amount, newExchangeRateMessage.date);
        commandBus.dispatch(addExchangeRateCommand);
    }
}

테스트:

@ExtendWith(SpringExtension.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
public class ExchangeRateStoreStreamListenerTest {
    @Autowired
    private ExchangeRateStoreStreamSink streamSink;

    @SpyBean
    private ExchangeRateStoreStreamListener streamListener;


    @Test
    public void test() {
        SubscribableChannel input = streamSink.newExchangeRate();
        NewExchangeRateMessage exchangeRateMessage = NewExchangeRateMessageFactory.aNewExchangeRateMessage();
        input.send(new GenericMessage<>(exchangeRateMessage));

        verify(streamListener).handle(any(NewExchangeRateMessage.class));
    }
}

AOP 측면:

@Aspect
@Component
public class LoggingAspect {
    private static final String API_DOMAIN = "fx";

    @Pointcut(value = "@annotation(loggable) && execution(* *(..))", argNames = "loggable")
    public void loggableMethod(Loggable loggable) { }

    @Around(value = "loggableMethod(loggable)", argNames = "pjp,loggable")
    public Object logAccess(ProceedingJoinPoint pjp, Loggable loggable) throws Throwable {
        final Signature signature = pjp.getSignature();

        final Logger logger = LogManager.getLogger(signature.getDeclaringType());

        logger.info( "api_domain={} _operation={} _message=\"Start operation\"",
                API_DOMAIN, loggable.operationName());
        try {
            return pjp.proceed();
        } catch (DomainError domainError) {
            // Some logic here
        }
    }
}

어떤 도움이든 환영합니다. 미리 감사드립니다!