http - 如何在 CXF SOAP 单向请求错误时设置响应状态代码

Question

我已经使用 Apache CXF(一个 dropwizard 应用程序)实现了一个@OneWay JAX-RS 服务。当使用无效结构调用时，会导致 DocLiteralInInterceptor 中出现解码错误，http 状态代码 200 会返回给客户端。为了让调用进程识别错误，我需要返回状态 400 或 500，以及来自 Unmarshalling Error 的错误文本。

我认识到，在错误之后，“in”拦截器链被展开(拦截器 handleFault 方法以相反的顺序调用)，所以我在“in”链的开头安装了一个拦截器(最后一个展开) 与

public CustomSOAPInterceptor(String chainname) {
    super(Phase.RECEIVE);
    getBefore().add(PolicyInInterceptor.class.getName());
    this.chainname=chainname;
}

在我的 handleFault-Method 中，我可以分离故障消息并识别解码错误。但我没有成功设置响应。

我试过了

Fault f = (Fault) e;
f.setStatusCode(Response.Status.BAD_REQUEST.getStatusCode());

和

Response response = Response
    .status(Response.Status.BAD_REQUEST)
    .entity(Response.Status.BAD_REQUEST.getStatusCode() + " " + f.getLocalizedMessage())
    .build();
soapMessage.getExchange().put(Response.class, response);

和

message.put(Message.RESPONSE_CODE, Response.Status.BAD_REQUEST.getStatusCode()); 

响应集在哪里，我如何覆盖它？

Tx 的任何建议。

Answer 1

我知道，有点晚了，但对于那些正在寻找解决方案的人来说:

在我的应用程序中，以下工作:

public void handleFault(SoapMessage soapMessage) {
    /* some code to test for specific error deleted */
    Exchange exchange = soapMessage.getExchange();
    Message outMessage = exchange.getOutMessage();
    if (outMessage == null) {
        Endpoint endpoint = exchange.get(Endpoint.class);
        outMessage = endpoint.getBinding().createMessage();
        exchange.setOutMessage(outMessage);
    }
    try {
        EndpointReferenceType target = exchange.get(EndpointReferenceType.class);
        Conduit conduit = exchange.getDestination().getBackChannel(soapMessage);
        exchange.setConduit(conduit);
        conduit.prepare(outMessage);

    } catch (IOException ex) {
        LOG.error(ex.getMessage(), ex);
    }
    Object resp = outMessage.get("HTTP.RESPONSE");

    if (resp != null && resp instanceof HttpServletResponse) {
        HttpServletResponse response = (HttpServletResponse) resp;
        response.setStatus(Response.Status.BAD_REQUEST.getStatusCode());
    }
    soapMessage.getInterceptorChain().abort();
}