org.apache.ignite.internal.processors.cache

Class DynamicCacheChangeFailureMessage

java.lang.Object

org.apache.ignite.internal.processors.cache.DynamicCacheChangeFailureMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class DynamicCacheChangeFailureMessage
extends Object
implements DiscoveryCustomMessage

This class represents discovery message that is used to provide information about dynamic cache start failure.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DynamicCacheChangeFailureMessage(ClusterNode locNode, GridDhtPartitionExchangeId exchId, IgniteCheckedException cause, Collection<String> cacheNames) Creates new DynamicCacheChangeFailureMessage instance.

Method Summary

Modifier and Type	Method and Description
@Nullable DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
Collection<String>	cacheNames()
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache) Creates new discovery cache if message caused topology version change.
IgniteCheckedException	error()
ExchangeActions	exchangeActions()
void	exchangeActions(ExchangeActions exchangeActions)
@Nullable GridDhtPartitionExchangeId	exchangeId()
IgniteUuid	id()
boolean	isMutable()
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

DynamicCacheChangeFailureMessage

public DynamicCacheChangeFailureMessage(ClusterNode locNode,
                                        GridDhtPartitionExchangeId exchId,
                                        IgniteCheckedException cause,
                                        Collection<String> cacheNames)

Creates new DynamicCacheChangeFailureMessage instance.

Parameters:

locNode - Local node.

exchId - Exchange Id.

cause - Cache start error.

cacheNames - Cache names.

Method Detail

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

cacheNames

public Collection<String> cacheNames()

Returns:

Collection of failed caches.

error

public IgniteCheckedException error()

Returns:

Cache start error.

exchangeActions

public ExchangeActions exchangeActions()

Returns:

Cache updates to be executed on exchange.

exchangeActions

public void exchangeActions(ExchangeActions exchangeActions)

Parameters:

exchangeActions - Cache updates to be executed on exchange.

exchangeId

@Nullable
public @Nullable GridDhtPartitionExchangeId exchangeId()

Returns:

Exchange version.

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.

toString

public String toString()

Overrides:

toString in class Object