Верблюд отправляет измененное тело в AMQ без изменения тела маршрута

Question

У меня есть rest-api, которые создают ресурс и отправляют его в очередь AMQ.

Я использую верблюд отдых и DSL создал что-то вроде этого:

rest("/api") 
      .consumes("application/json").produces("application/json") 
       .post("/test").type(Test.class) 
        .route() 
        .to(ExchangePattern.InOnly, "direct:sendTestAmq") 
        .endRest() 
from("direct:sendTestAmq") 
      .convertBodyTo(TestProtos.Test.class) 
      .marshal().protobuf() 
      .to(ExchangePattern.InOnly, "amq:queue:test.queue"); 

Когда я называю конечную точку, я получаю ответ base64, соответствующий Protobuf двоичный файл.

Я хотел бы получить ответ Test.class json. Я думал, что использовать «to (ExchangePattern.InOnly, ...)» позволит это, не изменяя тело.

Это еще один номер example, ответ «После», и я хотел, чтобы это было «раньше».

Кто-нибудь знает, как я могу это сделать?

Благодаря

Answer 1

На основе @ClausIbsen ответ я обнаружил, что многоадресного() также использовать копию обмена для каждого маршрута, но вместо прослушку, не Параллельная по-умолчанию.

Я мог бы достичь своей цели, заменив .to(ExchangePattern.InOnly, "direct:sendTestAmq") на multicast().to(ExchangePattern.InOnly, "direct:sendTestAmq", "direct:mock").end().

Поскольку multicast принимает в качестве результата последний обмен маршрутами, «direct: mock» - это маршрут, который ничего не сохраняет, кроме как сохраняет исходный корпус.