import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
protected Object performInvocation(Exchange cxfExchange, final Object serviceObject, Method method,
                                   Object[] paramArray) throws Exception {
    Object response = null;
    if (endpoint.isPerformInvocation()) {
        response = super.performInvocation(cxfExchange, serviceObject, method, paramArray);
    }
    paramArray = insertExchange(method, paramArray, cxfExchange);
    OperationResourceInfo ori = cxfExchange.get(OperationResourceInfo.class);        
    if (ori.isSubResourceLocator()) {
        // don't delegate the sub resource locator call to camel processor
        return method.invoke(serviceObject, paramArray);
    }
    Continuation continuation;
    if (!endpoint.isSynchronous() && (continuation = getContinuation(cxfExchange)) != null) {
        LOG.trace("Calling the Camel async processors.");
        return asyncInvoke(cxfExchange, serviceObject, method, paramArray, continuation, response);
    } else {
        LOG.trace("Calling the Camel sync processors.");
        return syncInvoke(cxfExchange, serviceObject, method, paramArray, response);
    }
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@SuppressWarnings("UnusedDeclaration")
public static void bind(final Exchange exchange) {
    if (exchange == null) {
        return;
    }

    final ClassResourceInfo cri = exchange.get(OperationResourceInfo.class).getClassResourceInfo();

    // binding context fields
    final Set<Class<?>> types = new HashSet<>();
    for (final Field field : cri.getContextFields()) {
        types.add(field.getType());
    }

    bind(exchange, types);
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@Override
public int compare(
    OperationResourceInfo oper1, OperationResourceInfo oper2,
    Message message) {

    return 0;
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@Override
public void handleMessage(Message message) throws Fault {
    final OperationResourceInfo operationResource = message.getExchange().get(OperationResourceInfo.class);
    if (operationResource == null) {
        log.info("OperationResourceInfo is not available, skipping validation");
        return;
    }

    final ClassResourceInfo classResource = operationResource.getClassResourceInfo();
    if (classResource == null) {
        log.info("ClassResourceInfo is not available, skipping validation");
        return;
    }

    final ResourceProvider resourceProvider = classResource.getResourceProvider();
    if (resourceProvider == null) {
        log.info("ResourceProvider is not available, skipping validation");
        return;
    }

    final List<Object> arguments = MessageContentsList.getContentsList(message);
    final Method method = operationResource.getAnnotatedMethod();
    final Object instance = resourceProvider.getInstance(message);
    if (method != null && arguments != null) {
        //validate the parameters(arguments) over the invoked method
        validate(method, arguments.toArray(), instance);

        //validate the fields of each argument
        for (Object arg : arguments) {
            if (arg != null)
                validate(arg);
        }
    }

}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@Override
public void handleMessage(XMLMessage message) throws Fault {
	Exchange exchange = message.getExchange();
	// TODO break out into a strategy (not JAXRS-specific)
	OperationResourceInfo operationResourceInfo = exchange.get(OperationResourceInfo.class);
	if (operationResourceInfo == null) {
		message.getInterceptorChain().doIntercept(message);
		return;
	}

	// TODO annotate with a better name?
	String methodName = operationResourceInfo.getMethodToInvoke().getName();
	// TODO annotate with a better name?
	Object key = operationResourceInfo.getClassResourceInfo().getResourceProvider()
			.getInstance();
	if (!(key instanceof Timeable)) {
		message.getInterceptorChain().doIntercept(message);
		return;
	}

	EventMetricCollector collector = timer.getCollector();
	collector.startTiming((Timeable) key, methodName);
	try {
		message.getInterceptorChain().doIntercept(message);
	} finally {
		collector.stopTiming();
	}
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@Override
public Response handleResponse(final Message m, final OperationResourceInfo ori, final Response response) {
    if(session!=null && session.isLive()) {
        session.logout();
        session = null;
    }
    return null;
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
private Object getServiceObject(final Message message) {
    final OperationResourceInfo ori = message.getExchange().get(OperationResourceInfo.class);
    if (ori == null) {
        return null;
    }
    if (!ori.getClassResourceInfo().isRoot()) {
        return message.getExchange().get("org.apache.cxf.service.object.last");
    }
    final ResourceProvider resourceProvider = ori.getClassResourceInfo().getResourceProvider();
    if (resourceProvider.isSingleton()) {
        return resourceProvider.getInstance(message);
    }
    final Object o = message.getExchange().get(CdiResourceProvider.INSTANCE_KEY);
    return o != null || !OpenEJBPerRequestPojoResourceProvider.class.isInstance(resourceProvider) ? o : resourceProvider.getInstance(message);
}
 

import org.apache.cxf.jaxrs.model.OperationResourceInfo; //导入依赖的package包/类
@Override
public Response handleResponse(Message message, OperationResourceInfo operationResourceInfo, Response response) {
    IdentityApplicationManagementUtil.resetThreadLocalProvisioningServiceProvider();
    return null;
}