Package org.apache.ignite.internal.processors.cluster

Class ChangeGlobalStateMessage

java.lang.Object

org.apache.ignite.internal.processors.cluster.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	Description
ChangeGlobalStateMessage(UUID reqId, UUID initiatingNodeId, @Nullable List<StoredCacheData> storedCfgs, ClusterState state, boolean forceDeactivation, BaselineTopology baselineTopology, boolean forceChangeBaselineTopology, long timestamp)

Method Summary

Modifier and Type	Method	Description
@Nullable DiscoveryCustomMessage	ackMessage()	Called when custom message has been handled by all nodes.
boolean	activate()	Deprecated. Use state() instead.
@Nullable BaselineTopology	baselineTopology()
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable ExchangeActions	exchangeActions()
boolean	forceChangeBaselineTopology()
boolean	forceDeactivation()
IgniteUuid	id()
UUID	initiatorNodeId()
boolean	isMutable()
UUID	requestId()
@Nullable ServiceDeploymentActions	servicesDeploymentActions()
void	servicesDeploymentActions(ServiceDeploymentActions serviceDeploymentActions)
ClusterState	state()
@Nullable List<StoredCacheData>	storedCacheConfigurations()
long	timestamp()
String	toString()

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

ChangeGlobalStateMessage

public ChangeGlobalStateMessage(UUID reqId,
                                UUID initiatingNodeId,
                                @Nullable
                                @Nullable List<StoredCacheData> storedCfgs,
                                ClusterState state,
                                boolean forceDeactivation,
                                BaselineTopology baselineTopology,
                                boolean forceChangeBaselineTopology,
                                long timestamp)

Parameters:

reqId - State change request ID.

initiatingNodeId - Node initiated state change.

storedCfgs - Configurations read from persistent store.

state - New cluster state.

forceDeactivation - If true, cluster deactivation will be forced.

baselineTopology - Baseline topology.

forceChangeBaselineTopology - Force change baseline topology flag.

timestamp - Timestamp.

Method Detail

storedCacheConfigurations

@Nullable
public @Nullable List<StoredCacheData> storedCacheConfigurations()

Returns:

Configurations read from persistent store..

exchangeActions

@Nullable
public @Nullable ExchangeActions exchangeActions()

Returns:

Cache updates to be executed on exchange. If null exchange is not needed.

servicesDeploymentActions

@Nullable
public @Nullable ServiceDeploymentActions servicesDeploymentActions()

Returns:

Services deployment actions to be processed on services deployment process.

servicesDeploymentActions

public void servicesDeploymentActions(ServiceDeploymentActions serviceDeploymentActions)

Parameters:

serviceDeploymentActions - Services deployment actions to be processed on services deployment process.

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

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.

initiatorNodeId

public UUID initiatorNodeId()

Returns:

Node initiated state change.

activate

@Deprecated
public boolean activate()

Deprecated.

Use state() instead.

Returns:

False if new cluster state is ClusterState.INACTIVE, and True otherwise.

state

public ClusterState state()

Returns:

New cluster state.

forceChangeBaselineTopology

public boolean forceChangeBaselineTopology()

Returns:

Force change BaselineTopology flag.

baselineTopology

@Nullable
public @Nullable BaselineTopology baselineTopology()

Returns:

Baseline topology.

forceDeactivation

public boolean forceDeactivation()

Returns:

True if cluster deactivation will be forced. False otherwise.

See Also:

ClusterState.INACTIVE

timestamp

public long timestamp()

Returns:

Timestamp.

requestId

public UUID requestId()

Returns:

State change request ID.

toString

public String toString()

Overrides:

toString in class Object