| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCache.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCache.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteMessaging.localListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
void |
IgniteCache.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
IgniteFuture<Void> |
IgniteCache.localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
<T extends Event> |
IgniteEvents.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
UUID |
IgniteMessaging.remoteListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
IgniteFuture<UUID> |
IgniteMessaging.remoteListenAsync(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
void |
IgniteMessaging.stopLocalListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterNodeAttributeAffinityBackupFilter
Attribute-based affinity backup filter that forces each partition's primary and backup nodes to different hardware
which is not expected to fail simultaneously, e.g., in AWS, to different "availability zones".
|
class |
ClusterNodeAttributeColocatedBackupFilter
This class can be used as a
RendezvousAffinityFunction.affinityBackupFilter to create
cache templates in Spring that force each partition's primary and backup to be co-located on nodes with the same
attribute value. |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> |
RendezvousAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> |
RendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setAffinityBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
| Constructor and Description |
|---|
RendezvousAffinityFunction(int parts,
@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<K,V> |
ScanQuery.getFilter()
Gets filter.
|
| Modifier and Type | Method and Description |
|---|---|
ScanQuery<K,V> |
ScanQuery.setFilter(@Nullable IgniteBiPredicate<K,V> filter)
Sets filter.
|
| Constructor and Description |
|---|
ScanQuery(@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
ScanQuery(@Nullable Integer part,
@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridifyNodeFilter
Predicate node filter.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteBiPredicate<K,V> |
CacheQueryExecutedEvent.scanQueryFilter()
Gets scan query filter.
|
@Nullable IgniteBiPredicate<K,V> |
CacheQueryReadEvent.scanQueryFilter()
Gets scan query filter.
|
| Constructor and Description |
|---|
CacheQueryExecutedEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName) |
CacheQueryReadEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName,
K key,
V val,
V oldVal,
@Nullable Object row) |
| Modifier and Type | Class and Description |
|---|---|
class |
SecurityAwareBiPredicate<E1,E2>
Security aware IgniteBiPredicate.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteMessagingImpl.localListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
<T extends Event> |
IgniteEventsImpl.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
UUID |
IgniteMessagingImpl.remoteListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
IgniteFuture<UUID> |
IgniteMessagingImpl.remoteListenAsync(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
void |
IgniteMessagingImpl.stopLocalListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Constructor and Description |
|---|
GridMessageListenHandler(@Nullable Object topic,
IgniteBiPredicate<UUID,Object> pred) |
SecurityAwareBiPredicate(UUID subjectId,
IgniteBiPredicate<E1,E2> original) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.addUserMessageListener(@Nullable Object topic,
@Nullable IgniteBiPredicate<UUID,?> p) |
void |
GridIoManager.addUserMessageListener(@Nullable Object topic,
@Nullable IgniteBiPredicate<UUID,?> p,
UUID nodeId) |
void |
GridIoManager.removeUserMessageListener(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p) |
| Modifier and Type | Method and Description |
|---|---|
WALIterator |
IgniteWriteAheadLogManager.replay(WALPointer start,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)
Invoke this method to iterate over the written log entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheProxyImpl.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
GatewayProtectedCacheProxy.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteInternalCache.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
IgniteCacheProxyImpl.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GatewayProtectedCacheProxy.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
@Nullable Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
IgniteInternalCache.localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
IgniteInternalFuture<?> |
GridCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
@Nullable Object[] args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.scanIterator(boolean keepBinary,
@Nullable IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
IgniteInternalCache.scanIterator(boolean keepBinary,
@Nullable IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.scanIterator(boolean keepBinary,
@Nullable IgniteBiPredicate<Object,Object> p) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridNearCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(@Nullable WALIterator it,
IgniteBiPredicate<WALPointer,WALRecord> recPredicate,
IgnitePredicate<DataEntry> entryPredicate)
Apply update from some iterator and with specific filters.
|
| Modifier and Type | Method and Description |
|---|---|
WALIterator |
FileWriteAheadLogManager.replay(WALPointer start,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)
Invoke this method to iterate over the written log entries.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteWalIteratorFactory.IteratorParametersBuilder |
IgniteWalIteratorFactory.IteratorParametersBuilder.addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter) |
IgniteWalIteratorFactory.IteratorParametersBuilder |
IgniteWalIteratorFactory.IteratorParametersBuilder.filter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<WALRecord.RecordType,WALPointer> |
RecordSerializerFactoryImpl.recordDeserializeFilter() |
| Modifier and Type | Method and Description |
|---|---|
RecordSerializerFactoryImpl |
RecordSerializerFactoryImpl.recordDeserializeFilter(@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
RecordSerializerFactory |
RecordSerializerFactory.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
| Constructor and Description |
|---|
RecordSerializerFactoryImpl(GridCacheSharedContext cctx,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter) |
RecordV1Serializer(RecordDataV1Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of V1 serializer.
|
RecordV2Serializer(RecordDataV2Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of Record V2 serializer.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteBiPredicate<K,V> |
GridCacheQueryManager.ScanQueryIterator.filter() |
IgniteBiPredicate<Object,Object> |
GridCacheQueryRequest.keyValueFilter() |
<K,V> @Nullable IgniteBiPredicate<K,V> |
GridCacheQueryAdapter.scanFilter() |
| Modifier and Type | Method and Description |
|---|---|
<T,R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(@Nullable IgniteBiPredicate<K,V> filter,
@Nullable IgniteClosure<T,R> trans,
@Nullable Integer part,
boolean keepBinary,
boolean forceLocal,
Boolean dataPageScanEnabled)
Creates user's predicate based scan query.
|
<R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(@Nullable IgniteBiPredicate<K,V> filter,
@Nullable Integer part,
boolean keepBinary,
Boolean dataPageScanEnabled)
Creates user's predicate based scan query.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
@Nullable IgniteBiPredicate<Object,Object> filter,
@Nullable IgniteClosure<Map.Entry,Object> transform,
@Nullable Integer part,
boolean keepBinary,
boolean forceLocal,
Boolean dataPageScanEnabled) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
@Nullable Integer part,
@Nullable String clsName,
String clause,
int limit,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<Object,Object> filter,
@Nullable Integer part,
boolean incMeta,
boolean keepBinary,
Boolean dataPageScanEnabled) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
int limit,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
@Nullable Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
boolean addDepInfo,
Boolean dataPageScanEnabled) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridSetQueryPredicate<K,V>
Predicate for query over
IgniteSet items. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapProcessor.removex(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from offheap space for the given key.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformEventFilterListener
Platform event filter and listener.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformCacheEntryFilter
Platform cache entry filter interface.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformCacheEntryFilterImpl
Interop filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformEventFilterListenerImpl
Platform event filter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformMessageFilter
Platform message filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformMessageFilterImpl
Platform message filter.
|
class |
PlatformMessageLocalFilter
Interop local filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgnitePredicate2X<E1,E2>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapMap.removex(int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
boolean |
GridOffHeapPartitionedMap.removex(int part,
int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridUnsafeMap.removex(int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
boolean |
GridUnsafePartitionedMap.removex(int part,
int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
P2<T1,T2>
Defines
alias for IgniteBiPredicate by extending it. |
interface |
PKV<K,V>
Defines
alias for GridPredicate2<K, V> by extending
IgnitePredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX2<T1,T2>
Defines
alias for IgnitePredicate2X by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorQueryScanRegexFilter
Filter scan results by specified substring in string presentation of key or value.
|
| Modifier and Type | Method and Description |
|---|---|
default IgniteBiPredicate<E1,E2> |
IgniteBiPredicate.and(IgniteBiPredicate<E1,E2> then)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
| Modifier and Type | Method and Description |
|---|---|
default IgniteBiPredicate<E1,E2> |
IgniteBiPredicate.and(IgniteBiPredicate<E1,E2> then)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MessagingListenActor<T>
Convenience actor-base adapter for
IgniteMessaging.localListen(Object, IgniteBiPredicate)
method. |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSpiContext.addLocalMessageListener(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Register an local message listener to receive messages sent by remote nodes.
|
void |
IgniteSpiContext.removeLocalMessageListener(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Removes a previously registered local message listener.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021