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

Constructor Summary

Constructors

Constructor and Description
CustomMessageWrapper(DiscoveryCustomMessage delegate)

Method Summary

Modifier and Type	Method and Description
@Nullable DiscoverySpiCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
DiscoveryCustomMessage	delegate()
boolean	isMutable()
boolean	stopProcess() Deprecated.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomMessageWrapper

public CustomMessageWrapper(DiscoveryCustomMessage delegate)

Parameters:

delegate - Delegate.

Method Detail

ackMessage

@Nullable
public @Nullable 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

@Deprecated
public boolean stopProcess()

Deprecated.

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