Class CustomMessageWrapper

    • Constructor Detail

      • CustomMessageWrapper

        public CustomMessageWrapper​(DiscoveryCustomMessage delegate)
        Parameters:
        delegate - Delegate.
    • Method Detail

      • 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. Note: this method is used then and only then the zookeeper discovery is configured.
        Specified by:
        stopProcess in interface DiscoverySpiCustomMessage
        Returns:
        True if message should not be sent to all nodes.