我使用骆驼反应流,我想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)));
此代码仅返回没有标题“内容类型”的文本我想我不明白它是如何工作的,所以如果有人可以给我发送一个带有教程的链接(因为我找不到),或者有人可以帮助我理解,那就太好了它。谢谢你的帮助