fangjian0423/rocketmq-binder-demo

Simple demos for using RocketMQ Binder in Spring Cloud Alibaba

rocketmq-binder-demo

Simple demos for RocketMQ Binder in Spring Cloud Alibaba

rocketmq-binder-demo's Issues

发送延迟消息无效

发送延迟消息无效。
@OverRide
public void run(String... args) throws Exception {
// int count = 5;
// for (int index = 1; index <= count; index++) {
// source.output().send(MessageBuilder.withPayload("msg-" + index)
// .setHeader("index", index).build());
// }
source.output().send(MessageBuilder
.withPayload(objectMapper.writeValueAsString(new Person(99, "Jim")))
.setHeader("index", 9999)
.setHeader("DELAY", "5")
.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
.build());
}

rocketmq-binder-concurrently-broker-retry-demo问题

rocketmq-binder-concurrently-broker-retry-demo 这个设置了重试次数1（配置文件直接拷demo的），但是为什么没有生效？

demo run error

2021-01-06 18:07:10.801 ERROR 19760 --- [enderExecutor_1] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, test-topic
See http://rocketmq.apache.org/docs/faq/ for further details.
2021-01-06 18:07:10.803 ERROR 19760 --- [enderExecutor_2] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, test-topic
See http://rocketmq.apache.org/docs/faq/ for further details.
2021-01-06 18:07:10.805 ERROR 19760 --- [enderExecutor_5] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, test-topic
See http://rocketmq.apache.org/docs/faq/ for further details.
2021-01-06 18:07:10.805 ERROR 19760 --- [enderExecutor_4] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, test-topic
See http://rocketmq.apache.org/docs/faq/ for further details.
2021-01-06 18:07:10.805 ERROR 19760 --- [enderExecutor_3] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, test-topic
See http://rocketmq.apache.org/docs/faq/ for further details.

问一下，这个成熟不

我用springcloudalibaba dubbo+stream时，老报java.lang.IllegalStateException: org.springframework.context.annotation.AnnotationConfigApplicationContext@1d31a360 has been closed already
这种错误。
好像stream和dubbo qosServer在启动时加载上下文顺序上有问题。

小毛病太多了。