org.apache.ignite.internal.managers.discovery

Class CustomMessageWrapper

java.lang.Object

org.apache.ignite.internal.managers.discovery.CustomMessageWrapper

All Implemented Interfaces:

Serializable, DiscoverySpiCustomMessage

public class CustomMessageWrapper
extends Object
implements DiscoverySpiCustomMessage

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
DiscoverySpiCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
DiscoveryCustomMessage	delegate()
boolean	isMutable()
boolean	stopProcess() Called on discovery coordinator node after listener is notified.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

ackMessage

@Nullable
public DiscoverySpiCustomMessage ackMessage()

Called when custom message has been handled by all nodes.

Specified by:

ackMessage in interface DiscoverySpiCustomMessage

Returns:

Ack message or null if ack is not required.

isMutable

public boolean isMutable()

Specified by:

isMutable in interface DiscoverySpiCustomMessage

Returns:

True if message can be modified during listener notification. Changes will be send to next nodes.

stopProcess

public boolean stopProcess()

Called on discovery coordinator node after listener is notified. If returns true then message is not passed to others nodes, if after this method DiscoverySpiCustomMessage.ackMessage() returns non-null ack message, it is sent to all nodes.

Specified by:

stopProcess in interface DiscoverySpiCustomMessage

Returns:

True if message should not be sent to all nodes.

delegate

public DiscoveryCustomMessage delegate()

Returns:

Delegate.

toString

public String toString()

Overrides:

toString in class Object