ApacheCamel-SedaEndpoint

Question

我正在尝试向异步路由发送消息，但它不起作用。我刚刚在github上创建了一个项目来模拟这个问题

@SpringBootApplication
public class SedaQueueApplication implements CommandLineRunner {

@Autowired
@EndpointInject(uri = "direct://direct-queue")
ProducerTemplate producerTemplate;

public static void main(String[] args) {
    SpringApplication.run(SedaQueueApplication.class, args);
}

@Override
public void run(String... strings) throws Exception {
    producerTemplate.sendBody("Teste Direct - Async");
}

@Component
class Router extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("direct://direct-queue").routeId("toAsync").to("seda://async-queue?size=100");

        from("seda://async-queue").routeId("toLog").log("${body}");
    }
}

Answer 1

1. 你有两条路线。在您指定的路线之一中seda://async-queue和其他seda://async-queue?size=100保持一致，即将“大小”属性添加到第一条路线或从第二条路线删除。它会像桃子一样工作
2. 原因是（不确定这是否是camel代码中的错误），在SedaComponent:：getOrCreateQueue中，他们也在比较size属性。因此，如果size属性（如果存在）与doeśn不匹配，则会出现异常

希望这有所帮助。