如何在Mule ESB3.8中从JAVA Transformer内部抛出自定义异常？

Question

骡子流曰：

1. HTTP和CXF组件公开了给出两个整数之和的web服务。发送入请求的对象为:

公共类AddValues{private int a；private int b；public setA（int a）{this.a=a；}public getA（）{return a；}public setB（int b）{this.b=b；}public getB（）{return b；}}

public class AddValuesBusinessLogic extends AbstractMessageTransformer 
{
    @Override
    public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException {
    MuleMessage muleMessage = message;
    AddValues addValues = (AddValues) muleMessage.getPayload();
    if (addValues.getA() == null || addValues.getB() == null ) {
        //Make an AddValueException object
        throw new Exception("Add value exception");
    }
    return null;
}

有人能建议一下在Mule ESB中从JAVA Transformer发送自定义SOAP故障的最佳方法是什么吗？

Answer 1

我找到了一个使用TransformerException和CXF OutFaultInterceptor的解决方案。我的做法是：

>

编写一个自定义transformer类，在其中添加验证规则。例如，如果我想抛出整数a或b为null的错误，我将添加一个自定义转换器AddValuesBusinessLogic.class并使用以下代码：

public class AddValuesBusinessLogic extends AbstractMessageTransformer 
{
    @Override
    public Object transformMessage(MuleMessage message, String outputEncoding) throws 
    TransformerException 
    {
        MuleMessage muleMessage = message;
        AddValues addValues = (AddValues) muleMessage.getPayload();
        if (addValues.getA() == null || addValues.getB() == null ) {
        //Make an AddValueException object
        throw new TransformerException(this,new AddValueException("BAD REQUEST"));
    }
    return "ALL OK";}

然后，这个异常将传播到CXF，我正在编写一个OutFaultInterceptor，如下所示：

public class AddValuesFaultInterceptor extends AbstractSoapInterceptor {

    private static final Logger logger = LoggerFactory.getLogger(AddValuesFaultInterceptor.class);

    public AddValuesFaultInterceptor() {
        super(Phase.MARSHAL);
    }

    public void handleMessage(SoapMessage soapMessage) throws Fault {
        Fault fault = (Fault) soapMessage.getContent(Exception.class);

        if (fault.getCause() instanceof org.mule.api.transformer.TransformerMessagingException) {           
            Element detail = fault.getOrCreateDetail();
            Element errorDetail = detail.getOwnerDocument().createElement("addValuesError");
            Element errorCode = errorDetail.getOwnerDocument().createElement("errorCode");
            Element message = errorDetail.getOwnerDocument().createElement("message");
            errorCode.setTextContent("400");
            message.setTextContent("BAD REQUEST");
            errorDetail.appendChild(errorCode);
            errorDetail.appendChild(message);
            detail.appendChild(errorDetail);
        }
    }
    private Throwable getOriginalCause(Throwable t) {
        if (t instanceof ComponentException && t.getCause() != null) {
            return t.getCause();
        } else {
            return t;
        }
    }
}

catch (com.sun.xml.ws.fault.ServerSOAPFaultException soapFaultException) {

    javax.xml.soap.SOAPFault fault = soapFaultException.getFault(); // <Fault> node
    javax.xml.soap.Detail detail = fault.getDetail(); // <detail> node
    java.util.Iterator detailEntries = detail.getDetailEntries(); // nodes under <detail>'
    while(detailEntries.hasNext()) {
        javax.xml.soap.DetailEntry detailEntry = (DetailEntry) detailEntries.next();
        System.out.println(detailEntry.getFirstChild().getTextContent());
        System.out.println(detailEntry.getLastChild().getTextContent());
    }   
}