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

Class ClientCacheChangeDummyDiscoveryMessage

java.lang.Object

org.apache.ignite.internal.processors.cache.AbstractCachePartitionExchangeWorkerTask

org.apache.ignite.internal.processors.cache.ClientCacheChangeDummyDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage, CachePartitionExchangeWorkerTask

public class ClientCacheChangeDummyDiscoveryMessage
extends AbstractCachePartitionExchangeWorkerTask
implements DiscoveryCustomMessage

Dummy discovery message which is not really sent via ring, it is just added in local discovery worker queue.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ClientCacheChangeDummyDiscoveryMessage(SecurityContext secCtx, UUID reqId, @Nullable Map<String,DynamicCacheChangeRequest> startReqs, @Nullable Set<String> cachesToClose)

Method Summary

Modifier and Type	Method	Description
@Nullable DiscoveryCustomMessage	ackMessage()	Called when custom message has been handled by all nodes.
@Nullable DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
IgniteUuid	id()
boolean	isMutable()
boolean	skipForExchangeMerge()
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.cache.AbstractCachePartitionExchangeWorkerTask

securityContext

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

ClientCacheChangeDummyDiscoveryMessage

public ClientCacheChangeDummyDiscoveryMessage(SecurityContext secCtx,
                                              UUID reqId,
                                              @Nullable
                                              @Nullable Map<String,DynamicCacheChangeRequest> startReqs,
                                              @Nullable
                                              @Nullable Set<String> cachesToClose)

Parameters:

secCtx - Security context in which current task must be executed.

reqId - Start request ID.

startReqs - Caches start requests.

cachesToClose - Cache to close.

Method Detail

skipForExchangeMerge

public boolean skipForExchangeMerge()

Specified by:

skipForExchangeMerge in interface CachePartitionExchangeWorkerTask

Returns:

False if exchange merge should stop if this task is found in exchange worker queue.

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