com.hazelcast.client.impl.protocol.template

Interface EventResponseTemplate

public interface EventResponseTemplate

Client Protocol Event Responses

Method Summary

Methods

Modifier and Type	Method and Description
void	Cache(int type, Set<CacheEventData> keys, int completionId)
void	CacheBatchInvalidation(String name, List<Data> keys, List<String> sourceUuids)
void	CacheInvalidation(String name, Data key, String sourceUuid)
void	CachePartitionLost(int partitionId, String uuid)
void	DistributedObject(String name, String serviceName, String eventType)
void	Entry(Data key, Data value, Data oldValue, Data mergingValue, int eventType, String uuid, int numberOfAffectedEntries)
void	Item(Data item, String uuid, int eventType)
void	MapPartitionLost(int partitionId, String uuid)
void	Member(Member member, int eventType)
void	MemberAttributeChange(String uuid, String key, int operationType, String value)
void	MemberSet(Set<Member> members)
void	PartitionLost(int partitionId, int lostBackupCount, Address source)
void	QueryCacheBatch(List<QueryCacheEventData> events, String source, int partitionId)
void	QueryCacheSingle(QueryCacheEventData data)
void	Topic(Data item, long publishTime, String uuid)

Method Detail

Member

void Member(Member member,
          int eventType)

Parameters:

member - Cluster member server

eventType - Type of the event. The possible values are: 1: Member added event. 2: Member removed event.

MemberAttributeChange

void MemberAttributeChange(String uuid,
                         String key,
                         int operationType,
                         @Nullable
                         String value)

Parameters:

uuid - Unique user id of the member serve

key - Name of the attribute changed

operationType - Type of the change. Possible values are: 1: An attribute is added 2: An attribute is removed

value - Value of the attribute. This field only exist for operation type of 1, otherwise this field is not transferred at all

MemberSet

void MemberSet(Set<Member> members)

Parameters:

members - The list of members in the cluster. It is used to retrieve the initial list in the cluster when the client registers for the membership events.

Entry

void Entry(@Nullable
         Data key,
         @Nullable
         Data value,
         @Nullable
         Data oldValue,
         @Nullable
         Data mergingValue,
         int eventType,
         String uuid,
         int numberOfAffectedEntries)

Parameters:

key - The key for the entry in the map.

value - The value of the entry in the map.

oldValue - The original value for the key in the map if exists.

mergingValue - The incoming merging value of the entry event.

eventType - Possible types are: ADDED(1) REMOVED(2) UPDATED(3) EVICTED(4) EVICT_ALL(5) CLEAR_ALL(6) MERGED(7)

uuid - The id of the member.

numberOfAffectedEntries - The number of entries affected in the map.

Item

void Item(@Nullable
        Data item,
        String uuid,
        int eventType)

Parameters:

item - Map data item.

uuid - The id of the server member.

eventType - There are two possible values: 1: ADDED 2: REMOVED

Topic

void Topic(Data item,
         long publishTime,
         String uuid)

Parameters:

item - The published item

publishTime - The time the topic is published.

uuid - The id of the server member.

PartitionLost

void PartitionLost(int partitionId,
                 int lostBackupCount,
                 @Nullable
                 Address source)

Parameters:

partitionId - The lost partition id.

lostBackupCount - The number of lost backups for the partition. O: the owner, 1: first backup, 2: second backup ...

source - The address of the node that dispatches the event.

DistributedObject

void DistributedObject(String name,
                     String serviceName,
                     String eventType)

Parameters:

name - Name of the DistributedObject instance

serviceName - Name of the service.

eventType - Can be one of the two values: "CREATED" "DESTROYED"

CacheInvalidation

void CacheInvalidation(String name,
                     @Nullable
                     Data key,
                     @Nullable
                     String sourceUuid)

Parameters:

name - Name of the cache.

key - The key for the entry.

sourceUuid - The id of the server member.

CacheBatchInvalidation

void CacheBatchInvalidation(String name,
                          List<Data> keys,
                          @Nullable
                          List<String> sourceUuids)

Parameters:

name - Name of the cache.

keys - The keys for the entries in batch invalidation.

sourceUuids - The ids of the server members.

MapPartitionLost

void MapPartitionLost(int partitionId,
                    String uuid)

Parameters:

partitionId - The partition id that has been lost for the given map

uuid - The id of the server member.

Cache

void Cache(int type,
         Set<CacheEventData> keys,
         int completionId)

Parameters:

type - The type of the event. Possible values for the event are: CREATED(1): An event type indicating that the cache entry was created. UPDATED(2): An event type indicating that the cache entry was updated, i.e. a previous mapping existed. REMOVED(3): An event type indicating that the cache entry was removed. EXPIRED(4): An event type indicating that the cache entry has expired. EVICTED(5): An event type indicating that the cache entry has evicted. INVALIDATED(6): An event type indicating that the cache entry has invalidated for near cache invalidation. COMPLETED(7): An event type indicating that the cache operation has completed. EXPIRATION_TIME_UPDATED(8): An event type indicating that the expiration time of cache record has been updated

keys - The keys for the entries in the cache.

completionId - User generated id which shall be received as a field of the cache event upon completion of the request in the cluster.

QueryCacheSingle

void QueryCacheSingle(QueryCacheEventData data)

Parameters:

data - Query cache map event data.

QueryCacheBatch

void QueryCacheBatch(List<QueryCacheEventData> events,
                   String source,
                   int partitionId)

Parameters:

events - Array of query cache events

source - Source of the event.

partitionId - The partition id for the query cache.

CachePartitionLost

void CachePartitionLost(int partitionId,
                      String uuid)