spring camel 使用一个实现类去处理web service的请求
2017-09-20 10:54
411 查看
参考: http://www.oschina.net/question/2416168_2133720
public class BeanTest {
public static void main(String[] args) throws Exception {
DefaultCamelContext context = new DefaultCamelContext();
RouteBuilder rb = new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct://a").to("bean:local.camel.BeanTest");
}
};
rb.addRoutesToCamelContext(context);
context.start();
ProducerTemplate template = context.createProducerTemplate(1);
DefaultExchange exc = new DefaultExchange(context);
exc.getIn().setHeader("CamelBeanMethodName", "say");
exc.getIn().setHeader("CamelBeanMultiParameterArray", "true");
exc.getIn().setBody(new String[]{"vidy","1001"});
template.send("direct://a", exc);
context.shutdown();
}
public void say(String user,String id){
System.out.println(user+":"+id);
}
}
public class BeanTest {
public static void main(String[] args) throws Exception {
DefaultCamelContext context = new DefaultCamelContext();
RouteBuilder rb = new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct://a").to("bean:local.camel.BeanTest");
}
};
rb.addRoutesToCamelContext(context);
context.start();
ProducerTemplate template = context.createProducerTemplate(1);
DefaultExchange exc = new DefaultExchange(context);
exc.getIn().setHeader("CamelBeanMethodName", "say");
exc.getIn().setHeader("CamelBeanMultiParameterArray", "true");
exc.getIn().setBody(new String[]{"vidy","1001"});
template.send("direct://a", exc);
context.shutdown();
}
public void say(String user,String id){
System.out.println(user+":"+id);
}
}
相关文章推荐
- 这是一个秒杀系统,即大量用户抢有限的商品,先到先得 用户并发访问流量非常大,需要分布式的机器集群处理请求 系统实现使用Java
- Struts2一个Action内包含多个请求处理方法的处理,method的使用方法,struts2中的路径问题,通配符映射
- 5.11 一个用Spring AOP实现异常处理和记录程序执行时间的实例
- Struts2一个Action内包含多个请求处理方法的处理,method的使用方法,struts2中的路径问题,通配符映射 (
- Struts2一个Action内包含多个请求处理方法的处理,method的使用方法,struts2中的路径问题,通配符映射
- 使用perl+MongoDB实现一个WEB站点请求耗时日志分析系统
- 在ASP.NET中使用IHttpHandler处理请求(如自实现AJAX)时,无法获得Session(或者说是Session 为 null)的原因及解决方法
- 如何在一个Spring工程下使用多数据源配置的改进实现
- 使用Spring实现异常统一处理【三】--java.lang.IllegalStateException: STREAM问题的解决
- (实战)Spring Portlet MVC处理请求分析以及如何快速架构一个Portlet项目
- 使用Spring实现异常统一处理【四】--error-page中对异常进行log
- 一个用Spring AOP实现异常处理和记录程序执行时间的实例--邵京国
- 使用 acl_cpp 库中的 http_request 类实现一个 HTTP 客户端请求的例子
- 使用点聚 weboffice 以及vsto、 web service 实现word 的自动化文档处理
- C#和Qt实现的对于异常处理的一个使用策略
- 使用Spring实现异常统一处理【一】
- 使用Select I/O模型来实现一个并发处理多个客户端的TCP服务器
- 使用QT实现一个图像处理软件1 —— 图片的加载和显示
- Struts2中一个Action多个请求处理方法的三种实现方式
- 使用Hibernate 和 Spring 实现一个事务持久层