org.apache.ignite.internal.util.distributed

Class InitMessage<I extends Serializable>

java.lang.Object

org.apache.ignite.internal.util.distributed.InitMessage<I>

Type Parameters:

I - Request type.

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class InitMessage<I extends Serializable>
extends Object
implements DiscoveryCustomMessage

Initiate message.

See Also:

DistributedProcess, FullMessage, SingleNodeMessage, Serialized Form

Constructor Summary

Constructors

Constructor and Description
InitMessage(UUID processId, DistributedProcess.DistributedProcessType type, I req, boolean waitClnRes)

Method Summary

Modifier and Type	Method and Description
@Nullable DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache) Creates new discovery cache if message caused topology version change.
IgniteUuid	id()
boolean	isMutable()
UUID	processId()
I	request()
String	toString()
int	type()
boolean	waitClientResults()

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

InitMessage

public InitMessage(UUID processId,
                   DistributedProcess.DistributedProcessType type,
                   I req,
                   boolean waitClnRes)

Parameters:

processId - Process id.

type - Process type.

req - Request.

Method Detail

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.

processId

public UUID processId()

Returns:

Process id.

type

public int type()

Returns:

Process type.

request

public I request()

Returns:

Request.

waitClientResults

public boolean waitClientResults()

Returns:

Whether coordinator waits client nodes results.

toString

public String toString()

Overrides:

toString in class Object