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

Methods

Modifier and Type	Method and Description
DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
boolean	exchangeNeeded()
IgniteUuid	id()
boolean	isMutable()
Collection<DynamicCacheChangeRequest>	requests()
Set<String>	restartingCaches()
DynamicCacheChangeBatch	restartingCaches(Set<String> restartingCaches)
boolean	startCaches()
void	startCaches(boolean startCaches)
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 send to next nodes.

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