创建 spring 个可轮询通道时出现异常

Question

我在我的界面中创建了一个可轮询频道：

Channels.java:

final String INPUT = "input";

@Input(INPUT)
PollableChannel input();

在我的服务中我有：

Service.java

@Autowired
@Qualifier(Channels.INPUT)
private PollableChannel input;

@ServiceActivator(inputChannel = Channels.INPUT)
public void method() {

    Message<?> msg = input.receive();

我无法启动我的 spring 应用程序，出现此异常：

**Caused by: java.lang.IllegalStateException: No factory found binding target type: org.springframework.messaging.PollableChannel for channelFactory**

注意：我的服务有一个输出通道，它工作正常，所以我没有post这里的代码

Answer 1

绑定不支持 PollableChannel。您可以查看有关此 here

的更多信息

创建 spring 个可轮询通道时出现异常

Exception while creating spring Pollable Channel

java

spring-cloud

spring-cloud-stream

spring-rabbit

rabbitmq-exchange