驼峰码头组件，自定义标题过滤器策略

Question

我使用camel框架处理jetty组件。

我有两个问题：

1）我使用大消息（约1mb）和jetty组件将消息正文读取到骆驼交换标头中。它会导致这样的错误：

WARN  header full: java.lang.RuntimeException: Header>6144

所以，我如何才能使jetty组件不将HttpRequest主体放入标头中？

2） 当我试图重写默认的HeaderFilterStrategy时，我编写了这样一段代码：

SimpleRegistry registry = new SimpleRegistry();
CamelContext context = new DefaultCamelContext(registry);

HeaderFilterStrategy strategy = new NewHeaderFilterStrategy();

registry.put("str", strategy);
context.addRoutes(new RouteBuilder() {
  public void configure() {

    from("jetty:http://my.host:32278/general-nr/notify?headerFilterStrategy=str")
    .....
});

它引起了这样的例外：

Exception in thread "main" org.apache.camel.FailedToCreateRouteException: Failed to create route route1: Route[[From[jetty:http://my.host:32278/general-nr/notify?hea... because of Failed to resolve endpoint: jetty://http://my.host:32278/general-nr/notify?headerFilterStrategy=str due to: Could not find a suitable setter for property: headerFilterStrategy as there isn't a setter method with same type: java.lang.String nor type conversion possible: No type converter available to convert from type: java.lang.String to the required type: org.apache.camel.spi.HeaderFilterStrategy with value str
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:177)
at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:722)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:1789)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1575)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1444)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1412)
at org.apache.camel.example.jmstofile.ElfRouterExample.main(ElfRouterExample.java:98)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)

原因：组织。阿帕奇。骆驼ResolveEndpointFailedException：未能解析终结点：jetty://http://my.host:32278/general-编号/通知？headerFilterStrategy=str原因：无法为属性headerFilterStrategy找到合适的setter，因为没有相同类型的setter方法：java。无法进行字符串或类型转换：没有可从类型java转换的类型转换器。所需类型的lang.字符串：org。阿帕奇。骆驼spi。组织中具有值str的HeaderFilterStrategy。阿帕奇。骆驼实施。DefaultCamelContext。位于org的getEndpoint（DefaultCamelContext.java:479）。阿帕奇。骆驼util。CamelContextHelper。位于org的getMandatoryEndpoint（CamelContextHelper.java:50）。阿帕奇。骆驼模型路由定义。resolveEndpoint（routedDefinition.java:187）位于org。阿帕奇。骆驼实施。DefaultRouteContext。resolveEndpoint（DefaultRouteContext.java:108）位于org。阿帕奇。骆驼实施。DefaultRouteContext。位于组织的resolveEndpoint（DefaultRouteContext.java:114）。阿帕奇。骆驼模型来自定义。resolveEndpoint（FromDefinition.java:72）位于org。阿帕奇。骆驼实施。DefaultRouteContext。位于org的getEndpoint（DefaultRouteContext.java:90）。阿帕奇。骆驼模型路由定义。在组织中添加路由（routeddefinition.java:857）。阿帕奇。骆驼模型路由定义。addRoutes（RoutedDefinition.java:172）。。。还有12个原因：java。lang.IllegalArgumentException：无法为属性headerFilterStrategy找到合适的setter，因为没有相同类型的setter方法：java。无法进行字符串或类型转换：没有可从类型java转换的类型转换器。所需类型的lang.字符串：org。阿帕奇。骆驼spi。组织中具有值str的HeaderFilterStrategy。阿帕奇。骆驼util。内省支持。位于org的setProperty（IntrospectionSupport.java:347）。阿帕奇。骆驼util。内省支持。位于org的setProperty（IntrospectionSupport.java:367）。阿帕奇。骆驼util。内省支持。org上的setProperties（IntrospectionSupport.java:297）。阿帕奇。骆驼util。EndpointHelper。位于org的setProperties（EndpointHelper.java:249）。阿帕奇。骆驼实施。默认组件。位于org的setProperties（DefaultComponent.java:222）。阿帕奇。骆驼组成部分码头。JettyHTTPC组件。在org上创建endpoint（JettyHttpComponent.java:226）。阿帕奇。骆驼实施。默认组件。在org上创建endpoint（DefaultComponent.java:91）。阿帕奇。骆驼实施。DefaultCamelContext。getEndpoint（DefaultCamelContext.java:461）。。。20多个

我做错了什么？

你好，叶甫盖尼

Answer 1

我发现的唯一一个决定-它是在jetty组件中扩展DefaultHttpBinda类并覆盖JettyComponent从HttpMessage填充HttpServletRequest的人口请求参数（）方法。

你好，叶甫盖尼