使用 Camel 发出 POST 请求

Question

我有一个骆驼路由配置为从 JMS 队列中读取并将其发布到服务。 我的路线是：

from("jms:queue")
.marshal()
.json(JsonLibrary.GSON)
.setHeader(Exchange.CONTENT_TYPE,constant("application/json"))
.setHeader(Exchange.HTTP_METHOD, constant("POST"))
.process(new Processor1())
.to("https4:xxxxxx?throwExceptionOnFailure=false")
.process(new MyProcessor())

我的配置：

HttpComponent httpc = getContext().getComponent("http4",HttpComponent.class);
httpc.setHttpConfiguaration(customHttpConfig())

在 customHttpConfig 中我设置了我的身份验证详细信息。

我从服务器收到 400 错误。但是我可以从 Postman api 访问服务器并获得成功的响应。

在我的 Processor1 类中（在发出请求之前），我能够打印消息的正文，其中包含我的对象的 json 表示。

但是在 POST 请求之后的处理器中，我正在这样做并得到以下响应：

Message in = exchange.getIn();
in.getBody(String.class); // print the error code 400
HttpServletRequest request = in.getBody(HttpServletRequest.class)// This is null.

我做错了什么？我需要将消息内容设置为我的发布请求的正文吗？

Answer 1

不会是String.class:

in.getBody(String.class);

首先检查服务器响应的类型，然后尝试打印或记录交换正文。

应该是HttpServletResponse:

HttpServletRequest request = in.getBody(HttpServletRequest.class)