org.apache.ignite.internal.processors.cache

Class DynamicCacheChangeBatch

java.lang.Object

org.apache.ignite.internal.processors.cache.DynamicCacheChangeBatch

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class DynamicCacheChangeBatch
extends Object
implements DiscoveryCustomMessage

Cache change batch.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DynamicCacheChangeBatch(Collection<DynamicCacheChangeRequest> reqs)

Method Summary

Modifier and Type	Method and Description
DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache) Creates new discovery cache if message caused topology version change.
boolean	exchangeNeeded()
IgniteUuid	id()
boolean	isMutable()
Collection<DynamicCacheChangeRequest>	requests()
Set<String>	restartingCaches()
DynamicCacheChangeBatch	restartingCaches(Set<String> restartingCaches)
boolean	startCaches()
void	startCaches(boolean startCaches)
boolean	stopProcess() See DiscoverySpiCustomMessage.stopProcess().
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicCacheChangeBatch

public DynamicCacheChangeBatch(Collection<DynamicCacheChangeRequest> reqs)

Parameters:

reqs - Requests.

Method Detail

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

ackMessage

@Nullable
public 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.

stopProcess

public boolean stopProcess()

See DiscoverySpiCustomMessage.stopProcess().

Specified by:

stopProcess in interface DiscoveryCustomMessage

Returns:

True if message should not be sent to others nodes after it was processed on coordinator.

createDiscoCache

public 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.

requests

public Collection<DynamicCacheChangeRequest> requests()

Returns:

Collection of change requests.

exchangeNeeded

public boolean exchangeNeeded()

Returns:

True if request should trigger partition exchange.

startCaches

public boolean startCaches()

Returns:

True if required to start all caches on client node.

restartingCaches

public DynamicCacheChangeBatch restartingCaches(Set<String> restartingCaches)

Parameters:

restartingCaches - Restarting caches.

restartingCaches

public Set<String> restartingCaches()

Returns:

Set of restarting caches.

startCaches

public void startCaches(boolean startCaches)

Parameters:

startCaches - True if required to start all caches on client node.

toString

public String toString()

Overrides:

toString in class Object