Tag: spring cloud stream

Spring云流 – 应用初始化后发送消息

我试图使用“spring cloud stream”向rabbitmq发送一条简单的消息。 基本上代码看起来像这样： @EnableBinding(Source.class) @SpringBootApplication public class SourceApplication { public static void main(String[] args) { SpringApplication.run(SourceApplication.class, args); } @Autowired Source source; @PostConstruct public void init() { source.send(MessageBuilder.withPayload(“payload”).build()); } } 然后我收到此错误消息： org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel ‘unknown.channel.name’.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=******, headers={id=c60dd5be-6576-99d5-fd1b-b1cb94c191c1, timestamp=1488651422892}] at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:93) at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423) […]

Spring云流动态支持路由消息

我想创建一个公共项目（使用spring cloud stream）根据消息内容动态地将消息路由到不同的（消费者）项目。 （rabbitmq作为消息代理） 春云流支持吗？ 如果没有，任何提议的方法来实现这一点？ 谢谢