如果发生错误并继续路由，Apache Camel从路由断开连接

Question

我有一个在运行时管理的RouteBuilder。我想在发送错误而不向客户端发送响应时断开我的客户端与路由的连接。我也需要在整个过程中保持路由。我可以做什么来断开客户端而不停止我的路线？任何帮助将不胜感激。

@Override 
public void configure() throws Exception { 

    onException(Exception.class) 
    .handled(true) 
    .process(new Processor() { 

     @Override 
     public void process(Exchange exchange) throws Exception { 
      Log.error(String.format(Constants.ERROR_ROUTING_TO, endPointFrom.toUrl(), endPointTo.toUrl(), 
       exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class))); 
      //TODO I WANT TO DISCONNECT FROM ROUTE HERE 
     } 

    }); 

    from(endPointFrom.toUrl()) 
    .routeId(endPointFrom.getId()) 
    .description(endPointFrom.toString()) 
    .process(new Processor() { 

     @Override 
     public void process(Exchange exchange) throws Exception { 


     } 
    }) 
    .to(endPointTo.toUrl()); 

} 

Answer 1

我通过交换变量设置为null的响应体等Apache的骆驼断开连接客户端不发送响应消息解决我的问题。

@Override 
public void configure() throws Exception { 

    onException(Exception.class) 
    .handled(true) 
    .process(new Processor() { 

     @Override 
     public void process(Exchange exchange) throws Exception { 
      Log.error(String.format(Constants.ERROR_ROUTING_TO, endPointFrom.toUrl(), endPointTo.toUrl(), 
       exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class))); 
       exchange.getOut().setBody(null); 
     } 

    }); 

    from(endPointFrom.toUrl()) 
    .routeId(endPointFrom.getId()) 
    .description(endPointFrom.toString()) 
    .process(new Processor() { 

     @Override 
     public void process(Exchange exchange) throws Exception { 

     } 

    }) 
    .to(endPointTo.toUrl()); 

}