Package io.quarkus.infinispan.client.runtime.cache

Class CacheInterceptor

java.lang.Object

io.quarkus.infinispan.client.runtime.cache.CacheInterceptor

Direct Known Subclasses:

CacheInvalidateAllInterceptor, CacheInvalidateInterceptor, CacheResultInterceptor

public abstract class CacheInterceptor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	CacheInterceptor.ReturnType

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BASE_PRIORITY
(package private) org.infinispan.client.hotrod.RemoteCacheManager	remoteCacheManager
protected static final String	UNHANDLED_ASYNC_RETURN_TYPE_MSG

Constructor Summary

Constructors

Constructor	Description
CacheInterceptor()

Method Summary

Modifier and Type	Method	Description
protected io.smallrye.mutiny.Uni<?>	asyncInvocationResultToUni(Object invocationResult, CacheInterceptor.ReturnType returnType)
protected Object	createAsyncResult(io.smallrye.mutiny.Uni<Object> cacheValue, CacheInterceptor.ReturnType returnType)
protected static CacheInterceptor.ReturnType	determineReturnType(Class<?> returnType)
protected Object	getCacheKey(Object[] methodParameterValues)
protected <T extends Annotation> CacheInterceptionContext<T>	getInterceptionContext(jakarta.interceptor.InvocationContext invocationContext, Class<T> interceptorBindingClass)
protected org.infinispan.client.hotrod.RemoteCacheManager	getRemoteCacheManager()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

BASE_PRIORITY

public static final int BASE_PRIORITY

See Also:

• Constant Field Values

UNHANDLED_ASYNC_RETURN_TYPE_MSG

protected static final String UNHANDLED_ASYNC_RETURN_TYPE_MSG

See Also:

• Constant Field Values

remoteCacheManager

org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager

Constructor Details

CacheInterceptor

public CacheInterceptor()

Method Details

getInterceptionContext

protected <T extends Annotation>
CacheInterceptionContext<T> getInterceptionContext(jakarta.interceptor.InvocationContext invocationContext,
 Class<T> interceptorBindingClass)

getRemoteCacheManager

protected org.infinispan.client.hotrod.RemoteCacheManager getRemoteCacheManager()

getCacheKey

protected Object getCacheKey(Object[] methodParameterValues)

determineReturnType

protected static CacheInterceptor.ReturnType determineReturnType(Class<?> returnType)

asyncInvocationResultToUni

protected io.smallrye.mutiny.Uni<?> asyncInvocationResultToUni(Object invocationResult,
 CacheInterceptor.ReturnType returnType)

createAsyncResult

protected Object createAsyncResult(io.smallrye.mutiny.Uni<Object> cacheValue,
 CacheInterceptor.ReturnType returnType)