com.hazelcast.internal.nearcache.impl.invalidation

Class InvalidationMetaDataFetcher

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.InvalidationMetaDataFetcher

Direct Known Subclasses:

ClientCacheInvalidationMetaDataFetcher, ClientMapInvalidationMetaDataFetcher, MemberMapInvalidationMetaDataFetcher

public abstract class InvalidationMetaDataFetcher
extends Object

Runs on Near Cache side, an instance of this task is responsible for fetching of all Near Caches' remote metadata like last sequence numbers and partition UUIDs. To see usage of this metadata visit: MetaDataGenerator. This class is abstract to provide different implementations on client and member sides.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	InvalidationMetaDataFetcher.MetadataHolder

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	ASYNC_RESULT_WAIT_TIMEOUT_MINUTES
protected ILogger	logger

Constructor Summary

Constructors

Constructor and Description
InvalidationMetaDataFetcher(ILogger logger)

Method Summary

Modifier and Type	Method and Description
protected abstract void	extractMemberMetadata(Member member, InternalCompletableFuture future, InvalidationMetaDataFetcher.MetadataHolder metadataHolder)
void	fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)
protected abstract InternalCompletableFuture	fetchMetadataOf(Address address, List<String> names)
protected abstract Collection<Member>	getDataMembers()
protected void	handleExceptionWhileProcessingMetadata(Member member, Exception e)
void	init(RepairingHandler handler)

Methods inherited from class java.lang.Object

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

Field Detail

ASYNC_RESULT_WAIT_TIMEOUT_MINUTES

protected static final int ASYNC_RESULT_WAIT_TIMEOUT_MINUTES

See Also:

Constant Field Values

logger

protected final ILogger logger

Constructor Detail

InvalidationMetaDataFetcher

public InvalidationMetaDataFetcher(ILogger logger)

Method Detail

init

public final void init(RepairingHandler handler)
                throws Exception

Throws:

Exception

fetchMetadata

public final void fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)

getDataMembers

protected abstract Collection<Member> getDataMembers()

extractMemberMetadata

protected abstract void extractMemberMetadata(Member member,
                                              InternalCompletableFuture future,
                                              InvalidationMetaDataFetcher.MetadataHolder metadataHolder)
                                       throws Exception

Throws:

Exception

fetchMetadataOf

protected abstract InternalCompletableFuture fetchMetadataOf(Address address,
                                                             List<String> names)

handleExceptionWhileProcessingMetadata

protected void handleExceptionWhileProcessingMetadata(Member member,
                                                      Exception e)