Package org.apache.ignite.internal.processors.cache

Class ClientCacheChangeDiscoveryMessage

java.lang.Object

org.apache.ignite.internal.processors.cache.ClientCacheChangeDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class ClientCacheChangeDiscoveryMessage
extends Object
implements DiscoveryCustomMessage

Sent from cache client node to asynchronously notify about started.closed client caches.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ClientCacheChangeDiscoveryMessage(Map<Integer,Boolean> startedCaches, Set<Integer> closedCaches)

Method Summary

Modifier and Type	Method	Description
@Nullable DiscoveryCustomMessage	ackMessage()	Called when custom message has been handled by all nodes.
@Nullable Set<Integer>	closedCaches()
@Nullable DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
boolean	empty()
IgniteUuid	id()
boolean	isMutable()
void	merge(@Nullable Map<Integer,Boolean> startedCaches, @Nullable Set<Integer> closedCaches)
@Nullable Map<Integer,Boolean>	startedCaches()
String	toString()
org.apache.ignite.internal.processors.cache.ClientCacheUpdateTimeout	updateTimeoutObject()
void	updateTimeoutObject(org.apache.ignite.internal.processors.cache.ClientCacheUpdateTimeout updateTimeoutObj)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage

stopProcess

Constructor Detail

ClientCacheChangeDiscoveryMessage

public ClientCacheChangeDiscoveryMessage(Map<Integer,Boolean> startedCaches,
                                         Set<Integer> closedCaches)

Parameters:

startedCaches - Started caches.

closedCaches - Closed caches.

Method Detail

merge

public void merge(@Nullable
                  @Nullable Map<Integer,Boolean> startedCaches,
                  @Nullable
                  @Nullable Set<Integer> closedCaches)

Parameters:

startedCaches - Started caches.

closedCaches - Closed caches.

empty

public boolean empty()

Returns:

True if there are no info about started/closed caches.

updateTimeoutObject

public org.apache.ignite.internal.processors.cache.ClientCacheUpdateTimeout updateTimeoutObject()

Returns:

Update timeout object.

updateTimeoutObject

public void updateTimeoutObject(org.apache.ignite.internal.processors.cache.ClientCacheUpdateTimeout updateTimeoutObj)

Parameters:

updateTimeoutObj - Update timeout object.

startedCaches

@Nullable
public @Nullable Map<Integer,Boolean> startedCaches()

Returns:

Started caches map (cache ID to near enabled flag).

closedCaches

@Nullable
public @Nullable Set<Integer> closedCaches()

Returns:

Closed caches.

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

ackMessage

@Nullable
public @Nullable DiscoveryCustomMessage ackMessage()

Called when custom message has been handled by all nodes.

Specified by:

ackMessage in interface DiscoveryCustomMessage

Returns:

Ack message or null if ack is not required.

isMutable

public boolean isMutable()

Specified by:

isMutable in interface DiscoveryCustomMessage

Returns:

True if message can be modified during listener notification. Changes will be sent to next nodes.

createDiscoCache

@Nullable
public @Nullable DiscoCache createDiscoCache(GridDiscoveryManager mgr,
                                             AffinityTopologyVersion topVer,
                                             DiscoCache discoCache)

Creates new discovery cache if message caused topology version change.

Specified by:

createDiscoCache in interface DiscoveryCustomMessage

Parameters:

mgr - Discovery manager.

topVer - New topology version.

discoCache - Current discovery cache.

Returns:

Reused discovery cache.

toString

public String toString()

Overrides:

toString in class Object