Package org.apache.ignite.internal.processors.marshaller

Class MissingMappingRequestMessage

  • All Implemented Interfaces:
    Serializable, Message
    public class MissingMappingRequestMessage
extends Object
implements Message
    Client node receives discovery messages in asynchronous mode so it is possible that all server nodes already accepted new mapping but clients are unaware about it. In this case it is possible for client node to receive a request to perform some operation on such class client doesn't know about its mapping. Upon receiving such request client sends an explicit MissingMappingRequestMessage mapping request to one of server nodes using CommunicationSPI and waits for MissingMappingResponseMessage response. If server node where mapping request was sent to leaves the cluster for some reason mapping request gets automatically resent to the next alive server node in topology.
    See Also:
    Serialized Form

    • Constructor Detail

      • MissingMappingRequestMessage

        public MissingMappingRequestMessage()
        Default constructor.

    • Method Detail

      • writeTo

        public boolean writeTo​(ByteBuffer buf,
                       MessageWriter writer)
        Writes this message to provided byte buffer.
        Specified by:
        writeTo in interface Message
        Parameters:
        buf - Byte buffer.
        writer - Writer.
        Returns:
        Whether message was fully written.

      • readFrom

        public boolean readFrom​(ByteBuffer buf,
                        MessageReader reader)
        Reads this message from provided byte buffer.
        Specified by:
        readFrom in interface Message
        Parameters:
        buf - Byte buffer.
        reader - Reader.
        Returns:
        Whether message was fully read.

      • directType

        public short directType()
        Gets message type.
        Specified by:
        directType in interface Message
        Returns:
        Message type.

      • fieldsCount

        public byte fieldsCount()
        Gets fields count.
        Specified by:
        fieldsCount in interface Message
        Returns:
        Fields count.

      • onAckReceived

        public void onAckReceived()
        Method called when ack message received.
        Specified by:
        onAckReceived in interface Message

      • platformId

        public byte platformId()

      • typeId

        public int typeId()