Class Publish.DecodeMessage

  • Enclosing class:
    Publish

    public class Publish.DecodeMessage
    extends java.lang.Object
    • Constructor Detail

      • DecodeMessage

        public DecodeMessage()
    • Method Detail

      • decodeRoot

        public RootV1.Root decodeRoot​(byte[] rootMessage)
                               throws java.lang.Exception
        Decode a root message
        Throws:
        java.lang.Exception
      • decodeShard

        public ShardV1.Shard decodeShard​(byte[] shardMessage)
                                  throws java.lang.Exception
        Validate a given shard message
        Parameters:
        shardMessage - the message to be parsed
        Returns:
        a validated, parsed shard message
        Throws:
        java.lang.Exception - If the message had any invalid properties
      • decodeRequest

        public RequestV1.Request decodeRequest​(byte[] requestMessage)
                                        throws java.lang.Exception
        Validate a given request message
        Parameters:
        requestMessage -
        Returns:
        Throws:
        java.lang.Exception
      • decodeReply

        public ReplyV1.Reply decodeReply​(byte[] replyMessage)
                                  throws java.lang.Exception
        Validate a given reply message
        Parameters:
        replyMessage -
        Returns:
        Throws:
        java.lang.Exception
      • decodeForward

        public ForwardV1.Forward decodeForward​(byte[] forwardMessage)
                                        throws java.lang.Exception
        Validate a given forward message
        Parameters:
        forwardMessage -
        Returns:
        Throws:
        java.lang.Exception