Class CustomMessageWrapper
- java.lang.Object
-
- org.apache.ignite.internal.managers.discovery.CustomMessageWrapper
-
- All Implemented Interfaces:
Serializable,DiscoverySpiCustomMessage
- Direct Known Subclasses:
SecurityAwareCustomMessageWrapper
public class CustomMessageWrapper extends Object implements DiscoverySpiCustomMessage
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CustomMessageWrapper(DiscoveryCustomMessage delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description @Nullable DiscoverySpiCustomMessageackMessage()Called when custom message has been handled by all nodes.DiscoveryCustomMessagedelegate()booleanisMutable()booleanstopProcess()Called on discovery coordinator node after listener is notified.StringtoString()
-
-
-
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:
ackMessagein interfaceDiscoverySpiCustomMessage- Returns:
- Ack message or
nullif ack is not required.
-
isMutable
public boolean isMutable()
- Specified by:
isMutablein interfaceDiscoverySpiCustomMessage- Returns:
Trueif 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 returnstruethen message is not passed to others nodes, if after this methodDiscoverySpiCustomMessage.ackMessage()returns non-null ack message, it is sent to all nodes. Note: this method is used then and only then the zookeeper discovery is configured.- Specified by:
stopProcessin interfaceDiscoverySpiCustomMessage- Returns:
Trueif message should not be sent to all nodes.
-
delegate
public DiscoveryCustomMessage delegate()
- Returns:
- Delegate.
-
-