|
Apache CXF example source code file (WebFaultOutInterceptor.java)
The Apache CXF WebFaultOutInterceptor.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.jaxws.interceptors; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.ResourceBundle; import java.util.logging.Level; import java.util.logging.Logger; import javax.xml.namespace.QName; import javax.xml.ws.WebFault; import org.w3c.dom.Node; import org.apache.cxf.common.classloader.ClassLoaderUtils; import org.apache.cxf.common.i18n.BundleUtils; import org.apache.cxf.common.logging.LogUtils; import org.apache.cxf.common.util.StringUtils; import org.apache.cxf.databinding.DataWriter; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.interceptor.FaultOutInterceptor; import org.apache.cxf.message.FaultMode; import org.apache.cxf.message.Message; import org.apache.cxf.service.Service; import org.apache.cxf.service.model.BindingOperationInfo; import org.apache.cxf.service.model.FaultInfo; import org.apache.cxf.service.model.MessagePartInfo; import org.apache.cxf.service.model.OperationInfo; public class WebFaultOutInterceptor extends FaultOutInterceptor { private static final Logger LOG = LogUtils.getL7dLogger(WebFaultOutInterceptor.class); private static final ResourceBundle BUNDLE = BundleUtils.getBundle(WebFaultOutInterceptor.class); public WebFaultOutInterceptor() { super(); } private QName getFaultName(WebFault wf, Class<?> cls, OperationInfo op) { String ns = wf.targetNamespace(); if (StringUtils.isEmpty(ns)) { ns = op.getName().getNamespaceURI(); } String name = wf.name(); if (StringUtils.isEmpty(name)) { name = cls.getSimpleName(); } return new QName(ns, name); } private WebFault getWebFaultAnnotation(Class<?> t) { WebFault fault = t.getAnnotation(WebFault.class); if (fault == null && t.getSuperclass() != null && Throwable.class.isAssignableFrom(t.getSuperclass())) { fault = getWebFaultAnnotation(t.getSuperclass()); } return fault; } public void handleMessage(Message message) throws Fault { Fault f = (Fault)message.getContent(Exception.class); Throwable cause = f.getCause(); WebFault fault = null; if (cause != null) { fault = getWebFaultAnnotation(cause.getClass()); } if (cause instanceof Exception && fault != null) { Exception ex = (Exception)cause; Object faultInfo = null; try { Method method = cause.getClass().getMethod("getFaultInfo", new Class[0]); faultInfo = method.invoke(cause, new Object[0]); } catch (NoSuchMethodException e) { faultInfo = createFaultInfoBean(fault, cause); } catch (InvocationTargetException e) { throw new Fault(new org.apache.cxf.common.i18n.Message("INVOCATION_TARGET_EXC", BUNDLE), e); } catch (IllegalAccessException e) { throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_INVOKE", BUNDLE), e); } catch (IllegalArgumentException e) { throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_INVOKE", BUNDLE), e); } Service service = message.getExchange().get(Service.class); try { DataWriter<Node> writer = service.getDataBinding().createWriter(Node.class); OperationInfo op = message.getExchange().get(BindingOperationInfo.class).getOperationInfo(); QName faultName = getFaultName(fault, cause.getClass(), op); MessagePartInfo part = getFaultMessagePart(faultName, op); if (f.hasDetails()) { writer.write(faultInfo, part, f.getDetail()); } else { writer.write(faultInfo, part, f.getOrCreateDetail()); if (!f.getDetail().hasChildNodes()) { f.setDetail(null); } } f.setMessage(ex.getMessage()); } catch (Exception nex) { //if exception occurs while writing a fault, we'll just let things continue //and let the rest of the chain try handling it as is. LOG.log(Level.WARNING, "EXCEPTION_WHILE_WRITING_FAULT", nex); } } else { FaultMode mode = message.get(FaultMode.class); if (mode == FaultMode.CHECKED_APPLICATION_FAULT) { //only convert checked exceptions with this //otherwise delegate down to the normal protocol specific stuff super.handleMessage(message); } } } private Object createFaultInfoBean(WebFault fault, Throwable cause) { if (!StringUtils.isEmpty(fault.faultBean())) { try { Class<?> cls = ClassLoaderUtils.loadClass(fault.faultBean(), cause.getClass()); if (cls != null) { Object ret = cls.newInstance(); //copy props Method meth[] = cause.getClass().getMethods(); for (Method m : meth) { if (m.getParameterTypes().length == 0 && (m.getName().startsWith("get") || m.getName().startsWith("is"))) { try { String name; if (m.getName().startsWith("get")) { name = "set" + m.getName().substring(3); } else { name = "set" + m.getName().substring(2); } Method m2 = cls.getMethod(name, m.getReturnType()); m2.invoke(ret, m.invoke(cause)); } catch (Exception e) { //ignore } } } return ret; } } catch (ClassNotFoundException e1) { //ignore } catch (InstantiationException e) { //ignore } catch (IllegalAccessException e) { //ignore } } LOG.fine("Using @WebFault annotated class " + cause.getClass().getName() + " as faultInfo since getFaultInfo() was not found"); return cause; } private MessagePartInfo getFaultMessagePart(QName qname, OperationInfo op) { for (FaultInfo faultInfo : op.getFaults()) { for (MessagePartInfo mpi : faultInfo.getMessageParts()) { String ns = null; if (mpi.isElement()) { ns = mpi.getElementQName().getNamespaceURI(); } else { ns = mpi.getTypeQName().getNamespaceURI(); } if (qname.getLocalPart().equals(mpi.getConcreteName().getLocalPart()) && qname.getNamespaceURI().equals(ns)) { return mpi; } } } return null; } } Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF WebFaultOutInterceptor.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.