Я пытаюсь обновить поток интеграции Spring в одном из моих существующих приложений с поддержкой Reactive Streams. Используемый подход состоит в том, чтобы изменить параметр и тип возвращаемого значения метода шлюза как Mono. Поток выполняется плавно, и когда ответ достигает шлюза, возникает исключение java.lang.IllegalArgumentException: beanFactory не должно иметь значение null
Я использую Spring Boot 2.3.0.
inputChannel - это DirectChannel
gatewayReplyChannel - это FluxMessageChannel
@MessagingGateway(name = "reactiveGateway")
public interface EntryGate {
@Gateway(requestChannel = "inputChannel", replyChannel = "gatewayReplyChannel")
Mono<String> process(final Mono<String> input);
}
Трассировка исключений
Caused by: java.lang.IllegalArgumentException: 'beanFactory' must not be null
at org.springframework.util.Assert.notNull(Assert.java:198)
at org.springframework.integration.channel.ChannelUtils.getErrorHandler(ChannelUtils.java:51)
at org.springframework.integration.endpoint.ReactiveStreamsConsumer.onInit(ReactiveStreamsConsumer.java:155)
at org.springframework.integration.context.IntegrationObjectSupport.afterPropertiesSet(IntegrationObjectSupport.java:214)
at org.springframework.integration.gateway.MessagingGatewaySupport.registerReplyMessageCorrelatorIfNecessary(MessagingGatewaySupport.java:806)
at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceiveMessageReactive(MessagingGatewaySupport.java:609)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.sendOrSendAndReceive(GatewayProxyFactoryBean.java:639)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invokeGatewayMethod(GatewayProxyFactoryBean.java:573)
Кто-нибудь может помочь?
