org.apache.ignite.internal.pagemem.snapshot

Class StartFullSnapshotAckDiscoveryMessage

java.lang.Object

org.apache.ignite.internal.pagemem.snapshot.StartFullSnapshotAckDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class StartFullSnapshotAckDiscoveryMessage
extends Object
implements DiscoveryCustomMessage

Message indicating that a snapshot has been started.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StartFullSnapshotAckDiscoveryMessage(long globalSnapshotId, boolean fullSnapshot, Map<Integer,Long> lastFullSnapshotIdForCache, Collection<String> cacheNames, Exception err, UUID initiatorNodeId, String msg)

Method Summary

Methods

Modifier and Type	Method and Description
DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
Collection<String>	cacheNames()
Exception	error()
boolean	fullSnapshot()
long	globalSnapshotId()
boolean	hasError()
IgniteUuid	id()
UUID	initiatorNodeId()
boolean	isMutable()
Long	lastFullSnapshotId(int cacheId)
String	message()

Methods inherited from class java.lang.Object

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

Constructor Detail

StartFullSnapshotAckDiscoveryMessage

public StartFullSnapshotAckDiscoveryMessage(long globalSnapshotId,
                                    boolean fullSnapshot,
                                    Map<Integer,Long> lastFullSnapshotIdForCache,
                                    Collection<String> cacheNames,
                                    Exception err,
                                    UUID initiatorNodeId,
                                    String msg)

Parameters:

globalSnapshotId - Snapshot ID.

err - Error.

cacheNames - Cache names.

Method Detail

cacheNames

public Collection<String> cacheNames()

Returns:

Cache names.

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

initiatorNodeId

public UUID initiatorNodeId()

Returns:

Initiator node id.

error

public Exception error()

Returns:

Error if start this process is not successfully.

hasError

public boolean hasError()

Returns:

True if message has error otherwise false.

globalSnapshotId

public long globalSnapshotId()

Returns:

Snapshot ID.

fullSnapshot

public boolean fullSnapshot()

message

public String message()

lastFullSnapshotId

@Nullable
public Long lastFullSnapshotId(int cacheId)

Parameters:

cacheId - Cache 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.