servicemixmapper.java

来自「bpel执行引擎用来执行bpel业务流程」· Java 代码 · 共 222 行

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.apache.ode.jbi.msgmap;

import java.util.Collection;
import java.util.Set;

import javax.jbi.messaging.MessagingException;
import javax.jbi.messaging.NormalizedMessage;
import javax.wsdl.Fault;
import javax.wsdl.Operation;
import javax.wsdl.Part;
import javax.xml.namespace.QName;
import javax.xml.transform.dom.DOMSource;

import org.apache.ode.bpel.iapi.Message;
import org.apache.ode.utils.DOMUtils;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

/**
 * Message mapper for dealing with the degenerate messages that servicemix components such as servicemix-http provide. These
 * messages are not normalized and hence do not conform to the JBI specification. They are in fact whatever the SOAP body element
 * happens to be. This mapper will make a reasonable attempt to handle these messages, which means don't count on it working.
 *
 */
public class ServiceMixMapper extends BaseXmlMapper implements Mapper {

    @SuppressWarnings("unchecked")
    public Recognized isRecognized(NormalizedMessage nmsMsg, Operation op) {
        // First of all, if we are not in ServiceMix, we exclude this
        // as a possibility.
        if (nmsMsg.getClass().getName().indexOf("servicemix") == -1) {
            __log.debug("Unrecognized message class: " + nmsMsg.getClass());
            return Recognized.FALSE;
        }

        Element msg;
        try {
            msg = parse(nmsMsg.getContent());
            if (__log.isDebugEnabled()) {
                __log.debug("isRecognized() message: " + prettyPrint(msg));
            }
        } catch (MessageTranslationException e) {
            __log.warn("Unable to parse message: ", e);
            return Recognized.FALSE;
        }

        if (op.getInput() == null) {
            __log.debug("no input def - unrecognized");
            return Recognized.FALSE;
        }

        if (op.getInput().getMessage() == null) {
            __log.debug("no message def - unrecognized");
            return Recognized.FALSE;
        }

        if (op.getInput().getMessage().getParts().size() == 0) {
            __log.debug("no message parts def - unsure");
            return Recognized.UNSURE;
        }

        for (String pname : ((Set<String>) op.getInput().getMessage().getParts().keySet())) {
            Part part = op.getInput().getMessage().getPart(pname);
            Element pdata = null;
            // servicemix-http has a (bad) habit of placing the SOAP body content directly in the normalized message
            QName elementName = part.getElementName();
            if (elementName != null && elementName.getLocalPart().equals(msg.getLocalName())
                    && elementName.getNamespaceURI().equals(msg.getNamespaceURI())) {
                pdata = msg;
            }
            if (pdata == null) {
                // with RPC semantic the body is wrapped by a partName which is same as bodyElementName
                pdata = DOMUtils.findChildByName(msg, new QName(null, part.getName()));
            }
            if (pdata == null) {
                __log.debug("no part data for " + part.getName() + " -- unrecognized.");
                return Recognized.FALSE;
            }
            if (part.getElementName() != null) {
                Element child = DOMUtils.getFirstChildElement(pdata);
                if (child == null) {
                    __log.debug("element part " + part.getName() + " does not contain element " + part.getElementName()
                            + " -- unrecognized");
                    return Recognized.FALSE;
                }

            }
        }

        return Recognized.TRUE;

    }

    public void toNMS(NormalizedMessage nmsMsg, Message odeMsg, javax.wsdl.Message msgdef, QName fault) throws MessagingException,
            MessageTranslationException {
        if (msgdef == null)
            throw new NullPointerException("msdef must not be null.");
        Element ode = odeMsg == null ? null : odeMsg.getMessage();
        Element part = ode == null ? null : DOMUtils.getFirstChildElement(ode);
        Element firstPartEl = part == null ? null : DOMUtils.getFirstChildElement(part);

        if (fault != null) {
            // We treat faults seperately as there are some assumption we can make, mainly that there is
            // a single part and it is an element part.

            if (msgdef.getParts().size() != 1)
                throw new MessageTranslationException("Message for fault \"" + fault + "\" does not contain exactly one part! Cannot map!");

            Part partDef = (Part) msgdef.getParts().values().iterator().next();
            if (partDef.getElementName() == null)
                throw new MessageTranslationException("Message for fault \"" + fault + "\" does not contain an element part.");

            if (firstPartEl == null) {
                // Oooops, our assumption did not pan out; we'll do our best i.e. create empty content.
                __log.warn("Proceessing fault \"" + fault + "\" with empty content (check your BPEL).");

                Document doc = newDocument();
                Element content = doc.createElementNS(partDef.getElementName().getNamespaceURI(), partDef.getElementName().getLocalPart());
                doc.appendChild(content);
                if (__log.isDebugEnabled())
                    __log.debug("toNMS() ode message (fault, BS): " + prettyPrint(content));
                nmsMsg.setContent(new DOMSource(doc));
            } else {
                if (__log.isDebugEnabled())
                    __log.debug("toNMS() ode message (fault): " + prettyPrint(firstPartEl));
                nmsMsg.setContent(new DOMSource(firstPartEl));
            }
            return;
        }

        if (msgdef.getParts().size() > 1 || ((Part) msgdef.getParts().values().iterator().next()).getElementName() == null) {
            // If we have more than one part, or a single non-element part, then we can't use the standard
            // NMS doc-lit like convention. Instead we place the entire message on the bus and hope for the
            // best.
            if (__log.isDebugEnabled())
                __log.debug("toNMS() ode message (rpc-like): " + prettyPrint(ode));
            nmsMsg.setContent(new DOMSource(ode));
            return;
        }

        if (__log.isDebugEnabled())
            __log.debug("toNMS() normalized message (doc-like):" + prettyPrint(firstPartEl));
        nmsMsg.setContent(new DOMSource(firstPartEl));
    }

    public void toODE(Message odeMsg, NormalizedMessage nmsMsg, javax.wsdl.Message msgdef) throws MessageTranslationException {
        Element nms = parse(nmsMsg.getContent());
        boolean docLit = false;

        if (__log.isDebugEnabled()) {
            __log.debug("toODE() normalized message:\n" + prettyPrint(nms));
        }

        for (String pname : ((Set<String>) msgdef.getParts().keySet())) {
            Part part = msgdef.getPart(pname);
            // servicemix-http has a (bad) habit of placing the SOAP body content directly in the normalized message
            QName elementName = part.getElementName();
            if (elementName != null && elementName.getLocalPart().equals(nms.getLocalName())
                    && elementName.getNamespaceURI().equals(nms.getNamespaceURI())) {
                docLit = true;
                break;
            }
        }
        if (docLit) {
            __log.debug("toODE() doc-like message ");

            Document doc = newDocument();
            Element message = doc.createElement("message");
            doc.appendChild(message);

            Part firstPart = (Part) msgdef.getOrderedParts(null).get(0);
            Element p = doc.createElement(firstPart.getName());
            message.appendChild(p);
            p.appendChild(doc.importNode(nms, true));
            odeMsg.setMessage(message);
        } else {
            __log.debug("toODE() rpc-like message ");
            // Simple, just pass along the message
            if (__log.isDebugEnabled()) {
                __log.debug("toODE() ode message:\n" + prettyPrint(nms));
            }
            odeMsg.setMessage(nms);
        }
    }

    public Fault toFaultType(javax.jbi.messaging.Fault jbiFlt, Collection<Fault> faults) throws MessageTranslationException {
        if (faults.isEmpty())
            return null;

        // anynone's guess really
        return faults.iterator().next();
    }

    private String prettyPrint(Element el) {
        try {
            return DOMUtils.prettyPrint(el);
        } catch (java.io.IOException ioe) {
            return ioe.getMessage();
        }
    }

}