|
Apache CXF example source code file (JAXRSInvoker.java)
The Apache CXF JAXRSInvoker.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.jaxrs; import java.lang.reflect.Method; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.ResourceBundle; import java.util.logging.Logger; import javax.ws.rs.WebApplicationException; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.MultivaluedMap; import javax.ws.rs.core.Response; import org.apache.cxf.common.i18n.BundleUtils; import org.apache.cxf.common.logging.LogUtils; import org.apache.cxf.common.util.ClassHelper; import org.apache.cxf.helpers.CastUtils; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.interceptor.InterceptorChain.State; import org.apache.cxf.jaxrs.impl.MetadataMap; import org.apache.cxf.jaxrs.lifecycle.ResourceProvider; import org.apache.cxf.jaxrs.model.ClassResourceInfo; import org.apache.cxf.jaxrs.model.MethodInvocationInfo; import org.apache.cxf.jaxrs.model.OperationResourceInfo; import org.apache.cxf.jaxrs.model.OperationResourceInfoStack; import org.apache.cxf.jaxrs.model.Parameter; import org.apache.cxf.jaxrs.model.ParameterType; import org.apache.cxf.jaxrs.model.URITemplate; import org.apache.cxf.jaxrs.provider.ProviderFactory; import org.apache.cxf.jaxrs.utils.InjectionUtils; import org.apache.cxf.jaxrs.utils.JAXRSUtils; import org.apache.cxf.message.Exchange; import org.apache.cxf.message.Message; import org.apache.cxf.message.MessageContentsList; import org.apache.cxf.service.invoker.AbstractInvoker; public class JAXRSInvoker extends AbstractInvoker { private static final Logger LOG = LogUtils.getL7dLogger(JAXRSServiceFactoryBean.class); private static final ResourceBundle BUNDLE = BundleUtils.getBundle(JAXRSInvoker.class); private static final String SERVICE_LOADER_AS_CONTEXT = "org.apache.cxf.serviceloader-context"; private static final String SERVICE_OBJECT_SCOPE = "org.apache.cxf.service.scope"; private static final String REQUEST_SCOPE = "request"; private static final String LAST_SERVICE_OBJECT = "org.apache.cxf.service.object.last"; private static final String REQUEST_WAS_SUSPENDED = "org.apache.cxf.service.request.suspended"; public JAXRSInvoker() { } public Object invoke(Exchange exchange, Object request) { Response response = exchange.get(Response.class); if (response != null) { // this means a blocking request filter provided a Response // or earlier exception has been converted to Response //TODO: should we remove response from exchange ? // or should we rather ignore content list and have // Response set here for all cases and extract it // in the out interceptor instead of dealing with the contents list ? return new MessageContentsList(response); } ResourceProvider provider = getResourceProvider(exchange); Object rootInstance = getServiceObject(exchange); Object serviceObject = getActualServiceObject(exchange, rootInstance); try { return invoke(exchange, request, serviceObject); } finally { boolean suspended = exchange.getInMessage().getInterceptorChain().getState() == State.SUSPENDED; if (!suspended) { if (exchange.isOneWay()) { ProviderFactory.getInstance(exchange.getInMessage()).clearThreadLocalProxies(); } if (!isServiceObjectRequestScope(exchange.getInMessage())) { provider.releaseInstance(exchange.getInMessage(), rootInstance); } else { persistRoots(exchange, rootInstance, provider); } } else { persistRoots(exchange, rootInstance, provider); exchange.put(REQUEST_WAS_SUSPENDED, true); } } } private void persistRoots(Exchange exchange, Object rootInstance, Object provider) { exchange.put(JAXRSUtils.ROOT_INSTANCE, rootInstance); exchange.put(JAXRSUtils.ROOT_PROVIDER, provider); } @SuppressWarnings("unchecked") public Object invoke(Exchange exchange, Object request, Object resourceObject) { OperationResourceInfo ori = exchange.get(OperationResourceInfo.class); ClassResourceInfo cri = ori.getClassResourceInfo(); boolean wasSuspended = exchange.remove(REQUEST_WAS_SUSPENDED) != null; if (!wasSuspended) { pushOntoStack(ori, ClassHelper.getRealClass(resourceObject), exchange.getInMessage()); if (cri.isRoot()) { JAXRSUtils.handleSetters(ori, resourceObject, exchange.getInMessage()); InjectionUtils.injectContextFields(resourceObject, ori.getClassResourceInfo(), exchange.getInMessage()); InjectionUtils.injectResourceFields(resourceObject, ori.getClassResourceInfo(), exchange.getInMessage()); } } Method methodToInvoke = InjectionUtils.checkProxy( cri.getMethodDispatcher().getMethod(ori), resourceObject); List<Object> params = null; if (request instanceof List) { params = CastUtils.cast((List<?>)request); } else if (request != null) { params = new MessageContentsList(request); } Object result = null; ClassLoader contextLoader = null; try { if (setServiceLoaderAsContextLoader(exchange.getInMessage())) { contextLoader = Thread.currentThread().getContextClassLoader(); Thread.currentThread().setContextClassLoader(resourceObject.getClass().getClassLoader()); } result = invoke(exchange, resourceObject, methodToInvoke, params); } catch (Fault ex) { Response excResponse = JAXRSUtils.convertFaultToResponse(ex.getCause(), exchange.getInMessage()); if (excResponse == null) { ProviderFactory.getInstance(exchange.getInMessage()).clearThreadLocalProxies(); ClassResourceInfo criRoot = (ClassResourceInfo)exchange.get(JAXRSUtils.ROOT_RESOURCE_CLASS); if (criRoot != null) { criRoot.clearThreadLocalProxies(); } exchange.put(Message.PROPOGATE_EXCEPTION, JAXRSUtils.propogateException(exchange.getInMessage())); throw ex; } return new MessageContentsList(excResponse); } finally { exchange.put(LAST_SERVICE_OBJECT, resourceObject); if (contextLoader != null) { Thread.currentThread().setContextClassLoader(contextLoader); } } if (ori.isSubResourceLocator()) { try { Message msg = exchange.getInMessage(); MultivaluedMap<String, String> values = getTemplateValues(msg); String subResourcePath = values.getFirst(URITemplate.FINAL_MATCH_GROUP); String httpMethod = (String)msg.get(Message.HTTP_REQUEST_METHOD); String contentType = (String)msg.get(Message.CONTENT_TYPE); if (contentType == null) { contentType = "*/*"; } List<MediaType> acceptContentType = (List<MediaType>)msg.getExchange().get(Message.ACCEPT_CONTENT_TYPE); result = checkResultObject(result, subResourcePath); ClassResourceInfo subCri = cri.getSubResource( methodToInvoke.getReturnType(), ClassHelper.getRealClass(result)); if (subCri == null) { org.apache.cxf.common.i18n.Message errorM = new org.apache.cxf.common.i18n.Message("NO_SUBRESOURCE_FOUND", BUNDLE, subResourcePath); LOG.severe(errorM.toString()); throw new WebApplicationException(404); } OperationResourceInfo subOri = JAXRSUtils.findTargetMethod(subCri, exchange.getInMessage(), httpMethod, values, contentType, acceptContentType, true); exchange.put(OperationResourceInfo.class, subOri); msg.put(URITemplate.TEMPLATE_PARAMETERS, values); // work out request parameters for the sub-resouce class. Here we // presume Inputstream has not been consumed yet by the root resource class. //I.e., only one place either in the root resource or sub-resouce class can //have a parameter that read from entitybody. List<Object> newParams = JAXRSUtils.processParameters(subOri, values, msg); msg.setContent(List.class, newParams); return this.invoke(exchange, newParams, result); } catch (WebApplicationException ex) { Response excResponse = JAXRSUtils.convertFaultToResponse(ex, exchange.getInMessage()); return new MessageContentsList(excResponse); } } return result; } @SuppressWarnings("unchecked") protected MultivaluedMap getTemplateValues(Message msg) { MultivaluedMap<String, String> values = new MetadataMap Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF JAXRSInvoker.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.