Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.notifications |
Notifications and eventing for listeners on both the Cache and CacheManager interfaces.
|
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.notifications.cachelistener.cluster | |
org.infinispan.notifications.cachelistener.filter |
Cache -specific notifications and eventing filtering classes. |
org.infinispan.security.impl |
Modifier and Type | Method and Description |
---|---|
<C> void |
AbstractDelegatingCache.addFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> void |
EncoderCache.addFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
AbstractDelegatingCache.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
CacheImpl.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
DecoratedCache.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
EncoderCache.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
SimpleCacheImpl.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> void |
AbstractDelegatingCache.addListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> void |
EncoderCache.addListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
AbstractDelegatingCache.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
CacheImpl.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
DecoratedCache.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
EncoderCache.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
SimpleCacheImpl.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> void |
AbstractDelegatingCache.addStorageFormatFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> void |
EncoderCache.addStorageFormatFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
AbstractDelegatingCache.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
CacheImpl.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
DecoratedCache.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
EncoderCache.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
SimpleCacheImpl.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
Modifier and Type | Method and Description |
---|---|
default <C> void |
DataConversionAwareListenable.addFilteredListener(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
default <C> void |
FilteringListenable.addFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations)
Registers a listener limiting the cache-entry specific events only to
annotations that are passed in as parameter.
|
<C> CompletionStage<Void> |
DataConversionAwareListenable.addFilteredListenerAsync(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
FilteringListenable.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations)
Asynchronous version of
FilteringListenable.addFilteredListener(Object, CacheEventFilter, CacheEventConverter, Set) |
default <C> void |
DataConversionAwareListenable.addListener(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader) |
default <C> void |
FilteringListenable.addListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter)
Registers a listener that will be notified on events that pass the filter condition.
|
default <C> void |
ClassLoaderAwareFilteringListenable.addListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader)
Adds a listener with the provided filter and converter and using a given classloader when invoked.
|
<C> CompletionStage<Void> |
DataConversionAwareListenable.addListenerAsync(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader) |
<C> CompletionStage<Void> |
FilteringListenable.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter)
Asynchronous version of
FilteringListenable.addListener(Object, CacheEventFilter, CacheEventConverter) |
<C> CompletionStage<Void> |
ClassLoaderAwareFilteringListenable.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader) |
default <C> void |
FilteringListenable.addStorageFormatFilteredListener(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations)
Same as
FilteringListenable.addFilteredListener(Object, CacheEventFilter, CacheEventConverter, Set) , but assumes the filter
and/or the converter will be done in the same data format as it's stored in the cache. |
<C> CompletionStage<Void> |
FilteringListenable.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations)
|
Modifier and Type | Field and Description |
---|---|
protected CacheEventConverter<? super K,? super V,?> |
CacheNotifierImpl.BaseCacheEntryListenerInvocation.converter |
Modifier and Type | Method and Description |
---|---|
CacheEventConverter<? super K,? super V,?> |
CacheNotifierImpl.CacheInvocationBuilder.getConverter() |
CacheEventConverter<? super K,? super V,?> |
CacheNotifierImpl.BaseCacheEntryListenerInvocation.getConverter() |
<C> CacheEventConverter<? super K,? super V,C> |
CacheEntryListenerInvocation.getConverter() |
Modifier and Type | Method and Description |
---|---|
<C> CompletionStage<Void> |
CacheNotifierImpl.addFilteredListenerAsync(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
CacheNotifierImpl.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
CacheNotifierImpl.addListenerAsync(ListenerHolder listenerHolder,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader) |
<C> CompletionStage<Void> |
CacheNotifierImpl.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
CacheNotifierImpl.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
ClassLoader classLoader)
Adds the listener using the provided filter converter and class loader.
|
<C> CompletionStage<Void> |
CacheNotifierImpl.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
protected CacheEntryEvent<K,V> |
CacheNotifierImpl.BaseCacheEntryListenerInvocation.convertValue(CacheEventConverter<? super K,? super V,?> converter,
CacheEntryEvent<K,V> event) |
CacheNotifierImpl.CacheInvocationBuilder |
CacheNotifierImpl.CacheInvocationBuilder.setConverter(CacheEventConverter<? super K,? super V,?> converter) |
protected <C> void |
CacheNotifierImpl.CacheInvocationBuilder.wireDependencies(CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
Constructor and Description |
---|
BaseCacheEntryListenerInvocation(EncoderRegistry encoderRegistry,
ListenerInvocation<Event<K,V>> invocation,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,?> converter,
Class<? extends Annotation> annotation,
boolean onlyPrimary,
boolean clustered,
UUID identifier,
boolean sync,
Listener.Observation observation,
Set<Class<? extends Annotation>> filterAnnotations,
DataConversion keyDataConversion,
DataConversion valueDataConversion,
boolean useStorageFormat) |
ClusteredListenerInvocation(EncoderRegistry encoderRegistry,
ListenerInvocation<Event<K,V>> invocation,
QueueingSegmentListener<K,V,CacheEntryEvent<K,V>> handler,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,?> converter,
Class<? extends Annotation> annotation,
boolean onlyPrimary,
UUID identifier,
boolean sync,
Listener.Observation observation,
Set<Class<? extends Annotation>> filterAnnotations,
DataConversion keyDataConversion,
DataConversion valueDataConversion,
boolean useStorageFormat) |
Constructor and Description |
---|
ClusterListenerReplicateCallable(String cacheName,
UUID identifier,
Address origin,
CacheEventFilter<K,V> filter,
CacheEventConverter<K,V,?> converter,
boolean sync,
Set<Class<? extends Annotation>> filterAnnotations,
DataConversion keyDataConversion,
DataConversion valueDataConversion,
boolean useStorageFormat) |
Modifier and Type | Interface and Description |
---|---|
interface |
CacheEventFilterConverter<K,V,C>
This interface is an optimization that can be used when an event filter and converter are most efficiently used as
the same object composing the filtering and conversion in the same method invocation.
|
interface |
IndexedFilter<K,V,C>
A marker interface for filters that can be handled efficiently by a
FilterIndexingServiceProvider . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheEventFilterConverter<K,V,C>
This is a base class that should be used when implementing a CacheEventFilterConverter that provides default
implementations for the
CacheEventFilter.accept(Object, Object, org.infinispan.metadata.Metadata, Object, org.infinispan.metadata.Metadata, EventType)
and Converter.convert(Object, Object, org.infinispan.metadata.Metadata) methods so they just call the
CacheEventFilterConverter.filterAndConvert(Object, Object, org.infinispan.metadata.Metadata, Object, org.infinispan.metadata.Metadata, EventType)
method and then do the right thing. |
class |
KeyValueFilterConverterAsCacheEventFilterConverter<K,V,C>
CacheEventFilterConverter that uses an underlying KeyValueFilterConverter to do the conversion and
filtering. |
Modifier and Type | Method and Description |
---|---|
<C> CacheEventConverter<? super K,? super V,C> |
DelegatingCacheEntryListenerInvocation.getConverter() |
<K,V,C> CacheEventConverter<K,V,C> |
CacheEventConverterFactory.getConverter(Object[] params)
Retrieves a cache event converter instance from this factory.
|
Constructor and Description |
---|
CacheEventConverterAsConverter(CacheEventConverter<K,V,C> converter) |
Modifier and Type | Method and Description |
---|---|
<C> CompletionStage<Void> |
SecureCacheImpl.addFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
<C> CompletionStage<Void> |
SecureCacheImpl.addListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter) |
<C> CompletionStage<Void> |
SecureCacheImpl.addStorageFormatFilteredListenerAsync(Object listener,
CacheEventFilter<? super K,? super V> filter,
CacheEventConverter<? super K,? super V,C> converter,
Set<Class<? extends Annotation>> filterAnnotations) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.