import org.apache.cxf.databinding.DataWriter; //导入依赖的package包/类
protected <T> DataWriter<T> getDataWriter(Message message, Service service, Class<T> output) {
    DataWriter<T> writer = service.getDataBinding().createWriter(output);
    
    Collection<Attachment> atts = message.getAttachments();
    if (MessageUtils.isTrue(message.getContextualProperty(Message.MTOM_ENABLED))
          && atts == null) {
        atts = new ArrayList<Attachment>();
        message.setAttachments(atts);
    }
    
    writer.setAttachments(atts);
    writer.setProperty(DataWriter.ENDPOINT, message.getExchange().getEndpoint());
    writer.setProperty(Message.class.getName(), message);
    
    setDataWriterValidation(service, message, writer);
    return writer;
}
 

import org.apache.cxf.databinding.DataWriter; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T> DataWriter<T> createWriter(Class<T> cls) {
    if (cls == XMLStreamWriter.class) {
        return (DataWriter<T>) new XMLStreamDataWriter() {

            public void write(Object obj, MessagePartInfo part, XMLStreamWriter output) {
                if (obj == null) {
                    return;
                }
                super.write(obj, part, output);
            }
            
        };
    } else if (cls == Node.class) {
        return (DataWriter<T>) new NodeDataWriter();
    } else {
        throw new UnsupportedOperationException("The type " + cls.getName() + " is not supported.");
    }
}
 

import org.apache.cxf.databinding.DataWriter; //导入依赖的package包/类
/**
 * Based on the Schema Validation configuration, will initialise the DataWriter with or without the schema set.
 */
private void setDataWriterValidation(Service service, Message message, DataWriter<?> writer) {
    if (shouldValidate(message)) {
        Schema schema = EndpointReferenceUtils.getSchema(service.getServiceInfos().get(0),
                                                         message.getExchange().getBus());
        writer.setSchema(schema);
    }
}
 

import org.apache.cxf.databinding.DataWriter; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@SuppressWarnings("unchecked")
public <T> DataWriter<T> createWriter(Class<T> cls) {
    ensureInitialized();
    if (cls.equals(XMLStreamWriter.class)) {
        return (DataWriter<T>)new XMLStreamDataWriter(this, getBus());
    } else if (cls.equals(Node.class)) {
        return (DataWriter<T>)new ElementDataWriter(this);
    } else {
        throw new UnsupportedOperationException();
    }
}
 

import org.apache.cxf.databinding.DataWriter; //导入依赖的package包/类
private Element render(Map<String, String> context) throws JAXBException, SOAPException {
	final MessageFactory messageFactory = MessageFactory.newInstance();
	final SOAPHeaderElement dummyContainerElement = messageFactory.createMessage().getSOAPHeader().addHeaderElement(new QName("http://test", "elem"));


	DataWriter<Node> writer = new JAXBDataBinding(TpicMap.class).createWriter(Node.class);
	writer.write(TpicMap.wrap(context), dummyContainerElement);

	return (Element) dummyContainerElement.getFirstChild();
}