org.apache.ignite.internal.processors.cache

Class ChangeGlobalStateMessage

java.lang.Object

org.apache.ignite.internal.processors.cache.ChangeGlobalStateMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class ChangeGlobalStateMessage
extends Object
implements DiscoveryCustomMessage

Message represent request for change cluster global state.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ChangeGlobalStateMessage(UUID requestId, UUID initiatingNodeId, boolean activate, DynamicCacheChangeBatch changeGlobalStateBatch)

Method Summary

Methods

Modifier and Type	Method and Description
DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
boolean	activate()
void	concurrentChangeState()
DynamicCacheChangeBatch	getDynamicCacheChangeBatch()
IgniteUuid	id()
UUID	initiatorNodeId()
boolean	isMutable()
UUID	requestId()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangeGlobalStateMessage

public ChangeGlobalStateMessage(UUID requestId,
                        UUID initiatingNodeId,
                        boolean activate,
                        DynamicCacheChangeBatch changeGlobalStateBatch)

Method Detail

getDynamicCacheChangeBatch

public DynamicCacheChangeBatch getDynamicCacheChangeBatch()

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.

initiatorNodeId

public UUID initiatorNodeId()

activate

public boolean activate()

requestId

public UUID requestId()

concurrentChangeState

public void concurrentChangeState()

toString

public String toString()

Overrides:

toString in class Object