apache-camel - Apache Camel 反应式 REST 内容类型

Question

我使用骆驼反应流，我想APPLICATION_JSON_UTF8_VALUE为响应添加内容类型。我试图将它添加到地图功能中。这是我的代码。

    @Autowired
    private CamelReactiveStreamsService camel;

    camel.process("rest:post:test", exchangeProperty ->
            Flux.from(exchangeProperty)
                    .map(ex -> {
                        ex.getIn().setHeader(Exchange.CONTENT_TYPE, MediaType.APPLICATION_JSON_UTF8_VALUE);
                        return ex;
                    })
                    .map(ex -> ex.getIn().getBody(String.class))
                    .flatMap(camel.toStream("testRest", String.class))
                    .doOnNext(ex -> System.out.println(ex)));

此代码仅返回没有标题“内容类型”的文本我想我不明白它是如何工作的，所以如果有人可以给我发送一个带有教程的链接（因为我找不到），或者有人可以帮助我理解，那就太好了它。谢谢你的帮助

标签： apache-camelreactivespring-camelreactor-nettycamel-http