使用Interceptor进行Apache CXFendpoint验证

Question

通过CXFendpoint中的模式验证，实现从CXFendpoint到JMS队列的驼峰路由。

已在CXF终结点中启用验证：

/* Set endpoint properties */
Map<String, Object> propertiesMap = new HashMap<String, Object>();
propertiesMap.put("schema-validation-enabled", "true");

/* Create endpoint */
CxfEndpoint cxfEndpoint = new CxfEndpoint();
cxfEndpoint.setWsdlURL("wsdl/input.wsdl");
cxfEndpoint.setDataFormat(DataFormat.CXF_MESSAGE);
cxfEndpoint.setProperties(propertiesMap);
cxfEndpoint.getInInterceptors().add(new FaultInterceptor());

骆驼路线：

from(cxfEndpoint)
.routeId("INPUT_ROUTE")
.to("jms:foo.bar");

CXF拦截器：

public class FaultInterceptor extends AbstractSoapInterceptor {

  private static final Logger LOGGER = Logger.getLogger(FaultInterceptor.class);

  public FaultInterceptor() {
    super(Phase.UNMARSHAL);
  }

  public void handleMessage(SoapMessage message) throws Fault {
    LOGGER.info("handleMessage=" + message.getExchange().getInMessage());    
  }

  @Override
  public void handleFault(SoapMessage message) {
    Fault fault = (Fault) message.getContent(Exception.class);
    LOGGER.info("handleFault='" + fault + "'");   
    /* Add some header property that says the message is invalid */  
  }

}

如果我发送有效的SOAP消息，则工作正常。如果我发送无效的SOAP消息，handleFault方法会启动，记录故障，仅此而已。对于无效的SOAP消息场景，我是否可以使用handleFault方法记录故障并仍然将无效消息路由到JMS队列？这是我添加到endpoint的唯一拦截器。

• Apache ServiceMix 5.0.0
• Apache Camel 2.12.3
• Apache CXF 2.7.10

Answer 1

您不能执行try/catch语句，因为错误发生在“from”子句中。

但是，您可以使用死信频道。

errorHandler(deadLetterChannel("jms:foo.bar.invalid"));

from(cxfEndpoint)
 .routeId("INPUT_ROUTE")
 .to("jms:foo.bar");