|
Apache CXF example source code file (JAXBEncoderDecoder.java)
The Apache CXF JAXBEncoderDecoder.java source code/** * 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.cxf.jaxb; import java.io.InputStream; import java.io.OutputStream; import java.lang.annotation.Annotation; import java.lang.reflect.Array; import java.lang.reflect.Constructor; import java.lang.reflect.Field; import java.lang.reflect.GenericArrayType; import java.lang.reflect.Method; import java.lang.reflect.Modifier; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.ArrayList; import java.util.Arrays; import java.util.Calendar; import java.util.Collection; import java.util.Enumeration; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.TreeMap; import java.util.logging.Logger; import javax.xml.bind.JAXBElement; import javax.xml.bind.JAXBException; import javax.xml.bind.Marshaller; import javax.xml.bind.Unmarshaller; import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.adapters.HexBinaryAdapter; import javax.xml.bind.attachment.AttachmentMarshaller; import javax.xml.bind.attachment.AttachmentUnmarshaller; import javax.xml.namespace.NamespaceContext; import javax.xml.namespace.QName; import javax.xml.stream.Location; import javax.xml.stream.XMLEventReader; import javax.xml.stream.XMLEventWriter; import javax.xml.stream.XMLStreamConstants; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import javax.xml.stream.XMLStreamWriter; import javax.xml.stream.util.StreamReaderDelegate; import javax.xml.transform.stream.StreamResult; import org.w3c.dom.Element; import org.w3c.dom.Node; import org.apache.cxf.common.i18n.Message; import org.apache.cxf.common.logging.LogUtils; import org.apache.cxf.common.util.SOAPConstants; import org.apache.cxf.common.util.StringUtils; import org.apache.cxf.helpers.CastUtils; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.service.model.MessagePartInfo; import org.apache.cxf.service.model.SchemaInfo; import org.apache.cxf.staxutils.DepthXMLStreamReader; import org.apache.cxf.staxutils.StaxUtils; import org.apache.cxf.staxutils.W3CDOMStreamWriter; import org.apache.ws.commons.schema.XmlSchemaElement; import org.apache.ws.commons.schema.XmlSchemaSimpleType; import org.apache.ws.commons.schema.XmlSchemaSimpleTypeList; /** * Utility functions for JAXB. */ public final class JAXBEncoderDecoder { private static final class AddXSITypeStreamReader extends StreamReaderDelegate { private boolean first = true; private final QName typeQName; private AddXSITypeStreamReader(XMLStreamReader reader, QName typeQName) { super(reader); this.typeQName = typeQName; } public int getAttributeCount() { return super.getAttributeCount() + (first ? 1 : 0); } public String getAttributeLocalName(int index) { if (first && index == 0) { return "type"; } return super.getAttributeLocalName(index - 1); } public QName getAttributeName(int index) { if (first && index == 0) { return new QName(SOAPConstants.XSI_NS, "type"); } return super.getAttributeName(index - 1); } public String getAttributeNamespace(int index) { if (first && index == 0) { return SOAPConstants.XSI_NS; } return super.getAttributeNamespace(index - 1); } public String getAttributePrefix(int index) { if (first && index == 0) { return "xsi"; } return super.getAttributePrefix(index - 1); } public String getAttributeType(int index) { if (first && index == 0) { return "#TEXT"; } return super.getAttributeType(index - 1); } public String getAttributeValue(int index) { if (first && index == 0) { String pfx = this.getNamespaceContext().getPrefix(typeQName.getNamespaceURI()); if (StringUtils.isEmpty(pfx)) { return typeQName.getLocalPart(); } return pfx + ":" + typeQName.getLocalPart(); } return super.getAttributeValue(index); } public int next() throws XMLStreamException { first = false; return super.next(); } public String getAttributeValue(String namespaceUri, String localName) { if (first && SOAPConstants.XSI_NS.equals(namespaceUri) && "type".equals(localName)) { String pfx = this.getNamespaceContext().getPrefix(typeQName.getNamespaceURI()); if (StringUtils.isEmpty(pfx)) { return typeQName.getLocalPart(); } return pfx + ":" + typeQName.getLocalPart(); } return super.getAttributeValue(namespaceUri, localName); } } private static final Logger LOG = LogUtils.getLogger(JAXBEncoderDecoder.class); private JAXBEncoderDecoder() { } @SuppressWarnings("unchecked") public static void marshall(Marshaller marshaller, Object elValue, MessagePartInfo part, Object source) { try { // The Marshaller.JAXB_FRAGMENT will tell the Marshaller not to // generate the xml declaration. marshaller.setProperty(Marshaller.JAXB_FRAGMENT, true); marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, false); } catch (javax.xml.bind.PropertyException e) { // intentionally empty. } Class<?> cls = null; if (part != null) { cls = part.getTypeClass(); } if (cls == null) { cls = null != elValue ? elValue.getClass() : null; } if (cls != null && cls.isArray() && elValue instanceof Collection) { Collection<?> col = (Collection)elValue; elValue = col.toArray((Object[])Array.newInstance(cls.getComponentType(), col.size())); } try { Object mObj = elValue; QName elName = null; if (part != null) { elName = part.getConcreteName(); } if (null != elName) { if (part != null && part.getXmlSchema() instanceof XmlSchemaElement) { XmlSchemaElement el = (XmlSchemaElement)part.getXmlSchema(); if (mObj.getClass().isArray() && el.getSchemaType() instanceof XmlSchemaSimpleType && ((XmlSchemaSimpleType)el.getSchemaType()). getContent() instanceof XmlSchemaSimpleTypeList) { mObj = Arrays.asList((Object[])mObj); writeObject(marshaller, source, new JAXBElement(elName, cls, mObj)); } else if (part.getMessageInfo().getOperation().isUnwrapped() && (mObj.getClass().isArray() || mObj instanceof List) && el.getMaxOccurs() != 1) { writeArrayObject(marshaller, source, elName, mObj); } else { writeObject(marshaller, source, new JAXBElement(elName, cls, mObj)); } } else if (byte[].class == cls && part.getTypeQName() != null && part.getTypeQName().getLocalPart().equals("hexBinary")) { mObj = new HexBinaryAdapter().marshal((byte[])mObj); writeObject(marshaller, source, new JAXBElement(elName, String.class, mObj)); } else if (mObj instanceof JAXBElement) { writeObject(marshaller, source, mObj); } else if (marshaller.getSchema() != null) { //force xsi:type so types can be validated instead of trying to //use the RPC/lit element names that aren't in the schema writeObject(marshaller, source, new JAXBElement(elName, Object.class, mObj)); } else { writeObject(marshaller, source, new JAXBElement(elName, cls, mObj)); } } else { writeObject(marshaller, source, mObj); } } catch (Fault ex) { throw (Fault)ex.fillInStackTrace(); } catch (Exception ex) { if (ex instanceof javax.xml.bind.MarshalException) { javax.xml.bind.MarshalException marshalEx = (javax.xml.bind.MarshalException)ex; Message faultMessage = new Message("MARSHAL_ERROR", LOG, marshalEx.getLinkedException() .getMessage()); throw new Fault(faultMessage, ex); } else { throw new Fault(new Message("MARSHAL_ERROR", LOG, ex.getMessage()), ex); } } } //TODO: cache the JAXBRIContext public static void marshalWithBridge(QName qname, Class<?> cls, Annotation anns[], Set<Class ctxClasses, Object elValue, Object source, AttachmentMarshaller am) { try { JAXBUtils.BridgeWrapper bridge = JAXBUtils.createBridge(ctxClasses, qname, cls, anns); if (source instanceof XMLStreamWriter) { bridge.marshal(elValue, (XMLStreamWriter)source, am); } else if (source instanceof OutputStream) { //the namespace is missing when marshal the xsd:QName type //to the OutputStream directly java.io.StringWriter sw = new java.io.StringWriter(); StreamResult s1 = new StreamResult(sw); bridge.marshal(elValue, s1); ((OutputStream)source).write(sw.toString().getBytes()); } else if (source instanceof Node) { bridge.marshal(elValue, (Node)source, am); } else { throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } } catch (Exception ex) { if (ex instanceof javax.xml.bind.MarshalException) { javax.xml.bind.MarshalException marshalEx = (javax.xml.bind.MarshalException)ex; Message faultMessage = new Message("MARSHAL_ERROR", LOG, marshalEx.getLinkedException() .getMessage()); throw new Fault(faultMessage, ex); } else { throw new Fault(new Message("MARSHAL_ERROR", LOG, ex.getMessage()), ex); } } } // TODO: cache the JAXBRIContext public static Object unmarshalWithBridge(QName qname, Class<?> cls, Annotation anns[], Set<Class ctxClasses, Object source, AttachmentUnmarshaller am) { try { JAXBUtils.BridgeWrapper bridge = JAXBUtils.createBridge(ctxClasses, qname, cls, anns); if (source instanceof XMLStreamReader) { //DOMUtils.writeXml(StaxUtils.read((XMLStreamReader)source), System.out); return bridge.unmarshal((XMLStreamReader)source, am); } else if (source instanceof InputStream) { return bridge.unmarshal((InputStream)source); } else if (source instanceof Node) { return bridge.unmarshal((Node)source, am); } else { throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } } catch (Exception ex) { if (ex instanceof javax.xml.bind.MarshalException) { javax.xml.bind.MarshalException marshalEx = (javax.xml.bind.MarshalException)ex; Message faultMessage = new Message("MARSHAL_ERROR", LOG, marshalEx.getLinkedException() .getMessage()); throw new Fault(faultMessage, ex); } else { throw new Fault(new Message("MARSHAL_ERROR", LOG, ex.getMessage()), ex); } } } @SuppressWarnings("unchecked") public static void marshallException(Marshaller marshaller, Exception elValue, MessagePartInfo part, Object source) { XMLStreamWriter writer = getStreamWriter(source); QName qn = part.getElementQName(); try { writer.writeStartElement("ns1", qn.getLocalPart(), qn.getNamespaceURI()); Class<?> cls = part.getTypeClass(); XmlAccessorType accessorType = cls.getAnnotation(XmlAccessorType.class); if (accessorType == null && cls.getPackage() != null) { accessorType = cls.getPackage().getAnnotation(XmlAccessorType.class); } XmlAccessType accessType = accessorType != null ? accessorType.value() : XmlAccessType.PUBLIC_MEMBER; String namespace = part.getElementQName().getNamespaceURI(); SchemaInfo sch = part.getMessageInfo().getOperation().getInterface() .getService().getSchema(namespace); if (sch != null) { if (!sch.isElementFormQualified()) { namespace = null; } } else { LOG.warning("Schema associated with " + namespace + " is null"); } for (Field f : cls.getDeclaredFields()) { if (JAXBContextInitializer.isFieldAccepted(f, accessType)) { QName fname = new QName(namespace, f.getName()); f.setAccessible(true); if (JAXBSchemaInitializer.isArray(f.getGenericType())) { writeArrayObject(marshaller, writer, fname, f.get(elValue)); } else { writeObject(marshaller, writer, new JAXBElement(fname, String.class, f.get(elValue))); } } } for (Method m : cls.getMethods()) { if (JAXBContextInitializer.isMethodAccepted(m, accessType)) { int idx = m.getName().startsWith("get") ? 3 : 2; String name = m.getName().substring(idx); name = Character.toLowerCase(name.charAt(0)) + name.substring(1); QName mname = new QName(namespace, name); if (JAXBSchemaInitializer.isArray(m.getGenericReturnType())) { writeArrayObject(marshaller, writer, mname, m.invoke(elValue)); } else { writeObject(marshaller, writer, new JAXBElement(mname, String.class, m.invoke(elValue))); } } } writer.writeEndElement(); writer.flush(); } catch (Exception e) { throw new Fault(new Message("MARSHAL_ERROR", LOG, e.getMessage()), e); } } @SuppressWarnings("unchecked") private static void writeArrayObject(Marshaller marshaller, Object source, QName mname, Object mObj) throws Fault, JAXBException { // Have to handle this ourselves.... which really // sucks.... but what can we do? if (mObj == null) { return; } Object objArray; Class cls = null; if (mObj instanceof List) { List<?> l = (List)mObj; objArray = l.toArray(new Object[l.size()]); cls = null; } else { objArray = mObj; cls = objArray.getClass().getComponentType(); } int len = Array.getLength(objArray); for (int x = 0; x < len; x++) { Object o = Array.get(objArray, x); writeObject(marshaller, source, new JAXBElement(mname, cls == null ? o.getClass() : cls, o)); } } public static Exception unmarshallException(Unmarshaller u, Object source, MessagePartInfo part) { XMLStreamReader reader; if (source instanceof XMLStreamReader) { reader = (XMLStreamReader)source; } else if (source instanceof Element) { reader = StaxUtils.createXMLStreamReader((Element)source); try { // advance into the node reader.nextTag(); } catch (XMLStreamException e) { // ignore } } else { throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } try { QName qn = part.getElementQName(); if (!qn.equals(reader.getName())) { throw new Fault(new Message("ELEMENT_NAME_MISMATCH", LOG, qn, reader.getName())); } Class<?> cls = part.getTypeClass(); Object obj = null; try { Constructor cons = cls.getConstructor(); obj = cons.newInstance(); } catch (NoSuchMethodException nse) { Constructor cons = cls.getConstructor(new Class[] {String.class}); obj = cons.newInstance(new Object[1]); } XmlAccessorType accessorType = cls.getAnnotation(XmlAccessorType.class); if (accessorType == null && cls.getPackage() != null) { accessorType = cls.getPackage().getAnnotation(XmlAccessorType.class); } XmlAccessType accessType = accessorType != null ? accessorType.value() : XmlAccessType.PUBLIC_MEMBER; reader.nextTag(); while (reader.getEventType() == XMLStreamReader.START_ELEMENT) { QName q = reader.getName(); try { Field f = cls.getField(q.getLocalPart()); Type type = f.getGenericType(); if (JAXBContextInitializer.isFieldAccepted(f, accessType)) { f.setAccessible(true); if (JAXBSchemaInitializer.isArray(type)) { Class<?> compType = JAXBSchemaInitializer .getArrayComponentType(type); List<Object> ret = unmarshallArray(u, reader, q, compType, createList(type)); Object o = ret; if (!isList(type)) { if (compType.isPrimitive()) { o = java.lang.reflect.Array.newInstance(compType, ret.size()); for (int x = 0; x < ret.size(); x++) { Array.set(o, x, ret.get(x)); } } else { o = ret.toArray((Object[])Array.newInstance(compType, ret.size())); } } f.set(obj, o); } else { f.set(obj, u.unmarshal(reader, f.getType())); } } } catch (NoSuchFieldException ex) { String s = Character.toUpperCase(q.getLocalPart().charAt(0)) + q.getLocalPart().substring(1); Method m = null; try { m = cls.getMethod("get" + s); } catch (NoSuchMethodException mex) { m = cls.getMethod("is" + s); } Type type = m.getGenericReturnType(); Method m2 = cls.getMethod("set" + s, m.getReturnType()); if (JAXBSchemaInitializer.isArray(type)) { Class<?> compType = JAXBSchemaInitializer .getArrayComponentType(type); List<Object> ret = unmarshallArray(u, reader, q, compType, createList(type)); Object o = ret; if (!isList(type)) { if (compType.isPrimitive()) { o = java.lang.reflect.Array.newInstance(compType, ret.size()); for (int x = 0; x < ret.size(); x++) { Array.set(o, x, ret.get(x)); } } else { o = ret.toArray((Object[])Array.newInstance(compType, ret.size())); } } m2.invoke(obj, o); } else { Object o = getElementValue(u.unmarshal(reader, m.getReturnType())); m2.invoke(obj, o); } } } return (Exception)obj; } catch (Exception e) { throw new Fault(new Message("MARSHAL_ERROR", LOG, e.getMessage()), e); } } private static void writeObject(Marshaller u, Object source, Object mObj) throws Fault, JAXBException { if (source instanceof XMLStreamWriter) { u.marshal(mObj, (XMLStreamWriter)source); } else if (source instanceof OutputStream) { u.marshal(mObj, (OutputStream)source); } else if (source instanceof Node) { u.marshal(mObj, (Node)source); } else if (source instanceof XMLEventWriter) { u.marshal(mObj, (XMLEventWriter)source); } else { throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } } private static XMLStreamWriter getStreamWriter(Object source) throws Fault { if (source instanceof XMLStreamWriter) { return (XMLStreamWriter)source; } else if (source instanceof OutputStream) { return StaxUtils.createXMLStreamWriter((OutputStream)source); } else if (source instanceof Node) { return new W3CDOMStreamWriter((Element)source); } throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } @SuppressWarnings("unchecked") public static void marshallNullElement(Marshaller marshaller, Object source, MessagePartInfo part) { Class<?> clazz = part != null ? (Class)part.getTypeClass() : null; try { writeObject(marshaller, source, new JAXBElement(part.getElementQName(), clazz, null)); } catch (JAXBException e) { throw new Fault(new Message("MARSHAL_ERROR", LOG, e.getMessage()), e); } } @SuppressWarnings("unchecked") public static Object unmarshall(Unmarshaller u, Object source, MessagePartInfo part, boolean unwrap) { Class<?> clazz = part != null ? (Class)part.getTypeClass() : null; if (clazz != null && Exception.class.isAssignableFrom(clazz) && part != null && Boolean.TRUE.equals(part.getProperty(JAXBDataBinding.class.getName() + ".CUSTOM_EXCEPTION"))) { return unmarshallException(u, source, part); } QName elName = part != null ? part.getConcreteName() : null; if (clazz != null && clazz.isArray() && part != null && part.getXmlSchema() instanceof XmlSchemaElement) { XmlSchemaElement el = (XmlSchemaElement)part.getXmlSchema(); if (el.getSchemaType() instanceof XmlSchemaSimpleType && ((XmlSchemaSimpleType)el.getSchemaType()).getContent() instanceof XmlSchemaSimpleTypeList) { Object obj = unmarshall(u, source, elName, null, unwrap); if (clazz.isArray() && obj instanceof List) { return ((List)obj).toArray((Object[])Array.newInstance(clazz.getComponentType(), ((List)obj).size())); } return obj; } else if (part.getMessageInfo().getOperation().isUnwrapped() && el.getMaxOccurs() != 1) { // must read ourselves.... List<Object> ret = unmarshallArray(u, source, elName, clazz.getComponentType(), createList(part)); Object o = ret; if (!isList(part)) { if (isSet(part)) { o = createSet(part, ret); } else if (clazz.getComponentType().isPrimitive()) { o = java.lang.reflect.Array.newInstance(clazz.getComponentType(), ret.size()); for (int x = 0; x < ret.size(); x++) { Array.set(o, x, ret.get(x)); } } else { o = ret.toArray((Object[])Array.newInstance(clazz.getComponentType(), ret.size())); } } return o; } } else if (byte[].class == clazz && part != null && part.getTypeQName() != null && part.getTypeQName().getLocalPart().equals("hexBinary")) { String obj = (String)unmarshall(u, source, elName, String.class, unwrap); return new HexBinaryAdapter().unmarshal(obj); } else if (part != null && u.getSchema() != null && !(part.getXmlSchema() instanceof XmlSchemaElement)) { //Validating RPC/Lit, make sure we don't try a root element name thing source = updateSourceWithXSIType(source, part.getTypeQName()); } Object o = unmarshall(u, source, elName, clazz, unwrap); if (o != null && o.getClass().isArray() && isList(part)) { List<Object> ret = createList(part); ret.addAll(Arrays.asList((Object[])o)); o = ret; } return o; } private static Object updateSourceWithXSIType(Object source, final QName typeQName) { if (source instanceof XMLStreamReader && typeQName != null) { XMLStreamReader reader = (XMLStreamReader)source; String type = reader.getAttributeValue(SOAPConstants.XSI_NS, "type"); if (StringUtils.isEmpty(type)) { source = new AddXSITypeStreamReader(reader, typeQName); } } return source; } private static Object createSet(MessagePartInfo part, List<Object> ret) { Type genericType = (Type)part.getProperty("generic.type"); Class tp2 = (Class)((ParameterizedType)genericType).getRawType(); if (tp2.isInterface()) { return new HashSet<Object>(ret); } Collection<Object> c; try { c = CastUtils.cast((Collection<?>)tp2.newInstance()); } catch (Exception e) { c = new HashSet<Object>(); } c.addAll(ret); return c; } private static boolean isSet(MessagePartInfo part) { if (part.getTypeClass().isArray() && !part.getTypeClass().getComponentType().isPrimitive()) { // && Collection.class.isAssignableFrom(part.getTypeClass())) { // it's List Para // Type genericType = (Type)part.getProperty("generic.type"); if (genericType instanceof ParameterizedType) { Type tp2 = ((ParameterizedType)genericType).getRawType(); if (tp2 instanceof Class) { return Set.class.isAssignableFrom((Class<?>)tp2); } } } return false; } private static List<Object> createList(MessagePartInfo part) { Type genericType = (Type)part.getProperty("generic.type"); return createList(genericType); } private static List<Object> createList(Type genericType) { if (genericType instanceof ParameterizedType) { Type tp2 = ((ParameterizedType)genericType).getRawType(); if (tp2 instanceof Class) { Class<?> cls = (Class)tp2; if (!cls.isInterface() && List.class.isAssignableFrom((Class<?>)cls)) { try { return CastUtils.cast((List)cls.newInstance()); } catch (Exception e) { // ignore, just return an ArrayList } } } } return new ArrayList<Object>(); } private static boolean isList(Type cls) { if (cls instanceof ParameterizedType) { return true; } return false; } private static boolean isList(MessagePartInfo part) { if (part.getTypeClass().isArray() && !part.getTypeClass().getComponentType().isPrimitive()) { // && Collection.class.isAssignableFrom(part.getTypeClass())) { // it's List Para // Type genericType = (Type)part.getProperty("generic.type"); if (genericType instanceof ParameterizedType) { Type tp2 = ((ParameterizedType)genericType).getRawType(); if (tp2 instanceof Class) { return List.class.isAssignableFrom((Class<?>)tp2); } } } return false; } public static Object unmarshall(Unmarshaller u, Object source, QName elName, Class<?> clazz, boolean unwrap) { Object obj = null; try { boolean unmarshalWithClass = true; if (clazz == null || (!clazz.isPrimitive() && !clazz.isArray() && !clazz.isEnum() && !clazz.equals(Calendar.class) && (Modifier.isAbstract(clazz.getModifiers()) || Modifier.isInterface(clazz.getModifiers())))) { unmarshalWithClass = false; } if (clazz != null && (clazz.getName().equals("javax.xml.datatype.XMLGregorianCalendar") || clazz.getName() .equals("javax.xml.datatype.Duration"))) { // special treat two jaxb defined built-in abstract types unmarshalWithClass = true; } if (source instanceof Node) { obj = unmarshalWithClass ? u.unmarshal((Node)source, clazz) : u.unmarshal((Node)source); } else if (source instanceof DepthXMLStreamReader) { // JAXB optimizes a ton of stuff depending on the StreamReader impl. Thus, // we REALLY want to pass the original reader in. This is OK with JAXB // as it doesn't read beyond the end so the DepthXMLStreamReader state // would be OK when it returns. The main winner is FastInfoset where parsing // a testcase I have goes from about 300/sec to well over 1000. DepthXMLStreamReader dr = (DepthXMLStreamReader)source; XMLStreamReader reader = dr.getReader(); if (u.getSchema() != null) { //validating, but we may need more namespaces reader = findExtraNamespaces(reader); } obj = unmarshalWithClass ? u.unmarshal(reader, clazz) : u .unmarshal(dr.getReader()); } else if (source instanceof XMLStreamReader) { XMLStreamReader reader = (XMLStreamReader)source; if (u.getSchema() != null) { //validating, but we may need more namespaces reader = findExtraNamespaces(reader); } obj = unmarshalWithClass ? u.unmarshal(reader, clazz) : u .unmarshal((XMLStreamReader)source); } else if (source instanceof XMLEventReader) { obj = unmarshalWithClass ? u.unmarshal((XMLEventReader)source, clazz) : u .unmarshal((XMLEventReader)source); } else { throw new Fault(new Message("UNKNOWN_SOURCE", LOG, source.getClass().getName())); } } catch (Fault ex) { ex.fillInStackTrace(); throw ex; } catch (Throwable ex) { if (ex instanceof javax.xml.bind.UnmarshalException) { javax.xml.bind.UnmarshalException unmarshalEx = (javax.xml.bind.UnmarshalException)ex; if (unmarshalEx.getLinkedException() != null) { throw new Fault(new Message("UNMARSHAL_ERROR", LOG, unmarshalEx.getLinkedException().getMessage()), ex); } else { throw new Fault(new Message("UNMARSHAL_ERROR", LOG, unmarshalEx.getMessage()), ex); } } else { throw new Fault(new Message("UNMARSHAL_ERROR", LOG, ex.getMessage()), ex); } } return unwrap ? getElementValue(obj) : obj; } private static XMLStreamReader findExtraNamespaces(XMLStreamReader source) { //due to a deficiency in the Stax API, there isn't a way to get all //the namespace prefixes that are "valid" at this point. Thus, JAXB //cannot set all the prefixes into the validator (which also doesn't allow //setting a NSContext, just allows declaring of prefixes) so resolving //prefixes and such will fail if they were declared on any of the parent //elements. // //We'll use some reflection to grab the known namespaces from woodstox //or the xerces parser and fake extra namespace decls on the root elements. //slight performance penalty, but there already is a penalty if you are validating //anyway. NamespaceContext c = source.getNamespaceContext(); final Map<String, String> nsMap = new TreeMap Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF JAXBEncoderDecoder.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.