tec*_*oma 1 java spring apache-camel
我正在尝试使用http://camel.apache.org/http.html 上指定的 producertemplate 调用我的简单 GET rest 服务调用。我在这里以 google.com 为例。这是来自未在任何容器上运行的独立客户端。我在这里没有做什么?
SpringCamelContext camelcontext = (SpringCamelContext) springContext.getBean("camelcontextbean");
ProducerTemplate template = camelcontext.createProducerTemplate();
camelcontext.start();
Exchange exchange = template.send("http://www.google.com/search", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.getIn().setHeader(Exchange.HTTP_QUERY, "hl=en&q=activemq");
}
});
Message out = exchange.getOut();
System.out.println("Response from http template is "+exchange.getOut().getBody());
System.out.println("status header is "+out.getHeader(Exchange.HTTP_RESPONSE_CODE));
Run Code Online (Sandbox Code Playgroud)
我没有得到任何回应。输出是:
来自 http 模板的响应为空
状态头为空
就好像你正在创建从春camelContext因为如果我删除,并得到了顺便做CamelContext关闭DefaultCamelContext我没有看到一个问题:
import org.apache.camel.*;
import org.apache.camel.impl.DefaultCamelContext;
public class Main {
public static void main(String ... args){
CamelContext camelContext = new DefaultCamelContext();
ProducerTemplate template = camelContext.createProducerTemplate();
Exchange exchange = template.send("http://www.google.com/search", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.getIn().setHeader(Exchange.HTTP_QUERY, "hl=en&q=activemq");
}
});
Message out = exchange.getOut();
System.out.println("Response from http template is "+exchange.getOut().getBody());
System.out.println("status header is "+out.getHeader(Exchange.HTTP_RESPONSE_CODE));
}
}
Run Code Online (Sandbox Code Playgroud)
产量
Response from http template is org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream@26659db7
status header is 200
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
9771 次 |
| 最近记录: |