将验证异常从Camel传递到CXF SOAP服务

Question

我有一个问题，我已经解决了一段时间，加上我是apache camel的新手，它没有帮助。

我的简单应用程序使用CXF（使用jetty作为http引擎）公开SOAP web服务，然后使用Camel将SOAP请求传递给akka参与者。

我希望在通往actor的道路上验证SOAP请求，并检查它是否包含某些头部和内容值。我不想使用CXF拦截器。问题是，camel中发生的事情（异常，错误消息返回）不会传播到CXF。我总是在日志中得到成功202作为响应和关于验证异常的信息。

class RequestActor extends Actor with WithLogger {
  def receive = {
    case CamelMessage(body: Request, headers) =>
      logger.info(s"Received Request $body [$headers]")
    case msg: CamelMessage =>
      logger.error(s"unknown message ${msg.body}")
  }
}

class CustomRouteBuilder(endpointUrl: String, serviceClassPath: String, system: ActorSystem)
  extends RouteBuilder {
  def configure {
    val requestActor = system.actorOf(Props[RequestActor])

    from(s"cxf:${endpointUrl}?serviceClass=${serviceClassPath}")
      .onException(classOf[PredicateValidationException])
        .handled(true)
        .process(new Processor {
        override def process(exchange: Exchange): Unit = {
          val message = MessageFactory.newInstance().createMessage();
          val envelope = message.getSOAPPart().getEnvelope();
          val body = message.getSOAPBody();
          val fault = body.addFault();
          fault.setFaultCode("Server");
          fault.setFaultString("Unexpected server error.");
          val detail = fault.addDetail();
          val entryName = envelope.createName("message");
          val entry = detail.addDetailEntry(entryName);
          entry.addTextNode("The server is not able to complete the request. Internal error.");

          log.info(s"Returning $message")
          exchange.getOut.setFault(true)
          exchange.getOut.setBody(message)
        }

        })
      .end()
      .validate(header("attribute").isEqualTo("for_sure_not_defined"))
      .to(genericActor)
  }
}

object Init extends App {

  implicit val system = ActorSystem("superman")
  val camel = CamelExtension(system)
  val camelContext = camel.context
  val producerTemplate = camel.template

  val endpointClassPath = classOf[Service].getName
  val endpointUrl = "http://localhost:1234/endpoint"

  camel.context.addRoutes(new CustomRouteBuilder(endpointUrl, endpointClassPath, system))

}

exchange.getOut.setFault(true)
exchange.getOut.setBody(message)

Answer 1

我不确定您在寻找什么，但我以不同的方式处理了CXFendpoint的异常。我必须在SOAPFault中返回带有自定义详细信息的HTTP-500（如验证错误消息等），所以...

>

保持Camel未处理的异常，以将其传递给CXF.onException(classof[PredicateValidationException]).handled（false）

创建org.apache.cxf.interceptor.fault对象，包含所有需要的异常细节。（不是肥皂错误）。它允许设置自定义详细信息元素，自定义FaultCode元素，消息。