public void handleMessage()

in cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperOutInterceptor.java [49:100]
48 lines of code
7 McCabe index (conditional complexity)

    public void handleMessage(Message message) throws Fault {
        BindingOperationInfo bop = message.getExchange().get(BindingOperationInfo.class);
        XMLStreamWriter xmlWriter = getXMLStreamWriter(message);
        Service service = message.getExchange().get(Service.class);
        
        DataWriter<XMLStreamWriter> dataWriter = getDataWriter(message, service, XMLStreamWriter.class);

        try {
            xmlWriter.setPrefix("jbi", NMRConstants.NS_JBI_WRAPPER);
            xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER,
                                        NMRConstants.JBI_WRAPPER_MESSAGE.getLocalPart());
            xmlWriter.writeNamespace("jbi", NMRConstants.NS_JBI_WRAPPER);
            
            List<MessagePartInfo> parts = null;
            if (!isRequestor(message)) {
                parts = bop.getOutput().getMessageParts();
            } else {
                parts = bop.getInput().getMessageParts();
            }
            List<?> objs = (List<?>) message.getContent(List.class);                
            if (objs.size() < parts.size()) {
                throw new Fault(new org.apache.cxf.common.i18n.Message(
                        "NOT_EQUAL_ARG_NUM", BUNDLE));
            }
            for (int idx = 0; idx < parts.size(); idx++) {
                MessagePartInfo part = parts.get(idx);
                Object obj = objs.get(idx);
                if (!part.isElement()) {
                    if (part.getTypeClass() == String.class) {
                        xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER,
                                                    NMRConstants.JBI_WRAPPER_PART.getLocalPart());
                        xmlWriter.writeCharacters(obj.toString());
                        xmlWriter.writeEndElement();
                    } else {
                        part = new MessagePartInfo(part.getName(), part.getMessageInfo());
                        part.setElement(false);
                        part.setConcreteName(NMRConstants.JBI_WRAPPER_PART);
                        dataWriter.write(obj, part, xmlWriter);
                    }
                } else {
                    xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER,
                                                NMRConstants.JBI_WRAPPER_PART.getLocalPart());
                    dataWriter.write(obj, part, xmlWriter);                    
                    xmlWriter.writeEndElement();
                }
            }
            xmlWriter.writeEndElement();
        
        } catch (XMLStreamException e) {
            throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_WRITE_EXC", BUNDLE), e);
        }
    }