public class MicroProfileClientProxyImpl extends ClientProxyImpl
ClientProxyImpl.BeanPair, ClientProxyImpl.BodyWriterAbstractClient.AbstractBodyWriter, AbstractClient.AbstractClientAsyncResponseInterceptorbodyWriter, BUFFER_PROXY_RESPONSE, BUNDLE, cri, inheritHeaders, isRoot, proxy, PROXY_METHOD_PARAM_BODY_INDEX, proxyLoader, SLASH, valuesMapcfg, EXECUTOR_SERVICE_PROPERTY, HTTP_SCHEME, KEEP_CONDUIT_ALIVE, REQUEST_CONTEXT, RESPONSE_CONTEXT| Constructor and Description |
|---|
MicroProfileClientProxyImpl(ClientState initialState,
ClassLoader loader,
ClassResourceInfo cri,
boolean isRoot,
boolean inheritHeaders,
ExecutorService executorService,
javax.ws.rs.core.Configuration configuration,
CDIInterceptorWrapper interceptorWrapper,
TLSConfiguration tlsConfig,
Object... varValues) |
MicroProfileClientProxyImpl(URI baseURI,
ClassLoader loader,
ClassResourceInfo cri,
boolean isRoot,
boolean inheritHeaders,
ExecutorService executorService,
javax.ws.rs.core.Configuration configuration,
CDIInterceptorWrapper interceptorWrapper,
TLSConfiguration tlsConfig,
Object... varValues) |
| Modifier and Type | Method and Description |
|---|---|
protected javax.ws.rs.client.InvocationCallback<Object> |
checkAsyncCallback(OperationResourceInfo ori,
Map<String,Object> reqContext,
Message outMessage) |
protected boolean |
checkAsyncReturnType(OperationResourceInfo ori,
Map<String,Object> reqContext,
Message outMessage) |
protected void |
checkResponse(Method m,
javax.ws.rs.core.Response r,
Message inMessage) |
void |
close()
Release the internal state and configuration associated with this client
|
protected Message |
createMessage(Object body,
OperationResourceInfo ori,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
URI currentURI,
Exchange exchange,
Map<String,Object> invocationContext,
boolean proxy) |
protected Object |
doInvokeAsync(OperationResourceInfo ori,
Message outMessage,
javax.ws.rs.client.InvocationCallback<Object> asyncCallback) |
protected void |
doRunInterceptorChain(Message message) |
protected Type |
getGenericReturnType(Class<?> serviceCls,
Method method,
Class<?> returnType) |
protected Class<?> |
getReturnType(Method method,
Message outMessage) |
TLSConfiguration |
getTlsConfig() |
protected void |
handleHeaders(Method m,
Object[] params,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
List<Parameter> beanParams,
javax.ws.rs.core.MultivaluedMap<ParameterType,Parameter> map) |
Object |
invoke(Object o,
Method m,
Object[] params)
Updates the current state if Client method is invoked, otherwise
does the remote invocation or returns a new proxy if subresource
method is invoked.
|
protected JaxrsClientCallback<?> |
newJaxrsClientCallback(javax.ws.rs.client.InvocationCallback<Object> asyncCallback,
Message outMessage,
Class<?> responseClass,
Type outGenericType) |
protected void |
setTimeouts(Map<String,Object> props) |
addFormValue, addNonEmptyPath, doChainedInvocation, doCheckAsyncCallback, findExceptionMapper, getAccept, getBodyIndex, getInvocationHandler, getMethodAnnotations, getMultipart, getParamAnnotations, getParameters, getParametersInfo, getPathParamValues, getValuesFromBeanParam, getValuesFromBeanParam, getValuesFromBeanParamField, handleCookies, handleForm, handleMatrixes, handleMultipart, handleQueries, handleResponse, isIgnorableParameter, reportInvalidResourceMethod, retryInvoke, setRequestHeadersaccept, accept, acceptEncoding, acceptLanguage, addMatrixQueryParamsToBuilder, authorization, calculateNewRequestURI, checkClientException, checkClosed, checkIfBodyEmpty, completeExchange, convertParamValue, convertParamValue, convertToWebApplicationException, cookie, createExchange, createMessage, encoding, findCallbackType, getBaseURI, getCallbackClass, getCallbackType, getConfiguration, getContentsList, getCurrentBuilder, getCurrentURI, getHeaders, getRequestContext, getResponse, getState, getTemplateParametersMap, header, headers, language, match, modified, parseQuotedHeaderValue, prepareConduitSelector, preProcessResult, query, readBody, removeAllHeaders, reportMessageHandlerProblem, reset, resetBaseAddress, resetCurrentBuilder, resetResponse, resetResponseStateImmediatelyIfNeeded, responseStreamCanBeClosed, retryInvoke, setAsyncMessageObserverIfNeeded, setConfiguration, setContexts, setEmptyRequestPropertyIfNeeded, setPlainOperationNameProperty, setResponseBuilder, setSupportOnewayResponseProperty, setupInFaultObserver, setupInInterceptorChain, setupOutInterceptorChain, type, type, waitForResponseCode, writeBodypublic MicroProfileClientProxyImpl(URI baseURI, ClassLoader loader, ClassResourceInfo cri, boolean isRoot, boolean inheritHeaders, ExecutorService executorService, javax.ws.rs.core.Configuration configuration, CDIInterceptorWrapper interceptorWrapper, TLSConfiguration tlsConfig, Object... varValues)
public MicroProfileClientProxyImpl(ClientState initialState, ClassLoader loader, ClassResourceInfo cri, boolean isRoot, boolean inheritHeaders, ExecutorService executorService, javax.ws.rs.core.Configuration configuration, CDIInterceptorWrapper interceptorWrapper, TLSConfiguration tlsConfig, Object... varValues)
protected javax.ws.rs.client.InvocationCallback<Object> checkAsyncCallback(OperationResourceInfo ori, Map<String,Object> reqContext, Message outMessage)
checkAsyncCallback in class ClientProxyImplprotected boolean checkAsyncReturnType(OperationResourceInfo ori, Map<String,Object> reqContext, Message outMessage)
protected Object doInvokeAsync(OperationResourceInfo ori, Message outMessage, javax.ws.rs.client.InvocationCallback<Object> asyncCallback)
doInvokeAsync in class ClientProxyImplprotected void doRunInterceptorChain(Message message)
doRunInterceptorChain in class AbstractClientprotected JaxrsClientCallback<?> newJaxrsClientCallback(javax.ws.rs.client.InvocationCallback<Object> asyncCallback, Message outMessage, Class<?> responseClass, Type outGenericType)
newJaxrsClientCallback in class ClientProxyImplprotected void checkResponse(Method m, javax.ws.rs.core.Response r, Message inMessage) throws Throwable
checkResponse in class ClientProxyImplThrowableprotected Class<?> getReturnType(Method method, Message outMessage)
getReturnType in class ClientProxyImplprotected Type getGenericReturnType(Class<?> serviceCls, Method method, Class<?> returnType)
getGenericReturnType in class ClientProxyImplprotected Message createMessage(Object body, OperationResourceInfo ori, javax.ws.rs.core.MultivaluedMap<String,String> headers, URI currentURI, Exchange exchange, Map<String,Object> invocationContext, boolean proxy)
createMessage in class ClientProxyImplprotected void handleHeaders(Method m, Object[] params, javax.ws.rs.core.MultivaluedMap<String,String> headers, List<Parameter> beanParams, javax.ws.rs.core.MultivaluedMap<ParameterType,Parameter> map)
handleHeaders in class ClientProxyImplpublic Object invoke(Object o, Method m, Object[] params) throws Throwable
ClientProxyImplinvoke in interface InvocationHandlerinvoke in class ClientProxyImplThrowablepublic void close()
Clientclose in interface Closeableclose in interface AutoCloseableclose in interface Clientclose in class AbstractClientpublic TLSConfiguration getTlsConfig()
Apache CXF