Apache Camel Reactive тип содержимого REST - PullRequest
Новая
       18

Apache Camel Reactive тип содержимого REST

0 голосов
/ 13 марта 2019

Я использую реактивные потоки верблюда, и я хотел бы добавить тип ответа 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)));

Этот код возвращает только текст без заголовка «тип содержимого» Я думаю, что я не понимаю, как это работает, поэтому было бы хорошо, если кто-то может отправить мне ссылку с руководством (потому что я не могу найти), или кто-то может помочь мне понять это. Спасибо за помощь

...