Class AZMessageFactory


  • public class AZMessageFactory
    extends java.lang.Object
    Factory for handling AZ message creation. NOTE: wire format: [total message length] + [id length] + [id bytes] + [version byte] + [payload bytes]
    • Constructor Detail

      • AZMessageFactory

        public AZMessageFactory()
    • Method Detail

      • init

        public static void init()
        Initialize the factory, i.e. register the messages with the message manager.
      • registerGenericMapPayloadMessageType

        public static void registerGenericMapPayloadMessageType​(java.lang.String type_id)
                                                         throws MessageException
        Register a generic map payload type with the factory.
        Parameters:
        type_id - to register
        Throws:
        MessageException - on registration error
      • createAZMessage

        public static Message createAZMessage​(DirectByteBuffer stream_payload)
                                       throws MessageException
        Construct a new AZ message instance from the given message raw byte stream.
        Parameters:
        stream_payload - data
        Returns:
        decoded/deserialized AZ message
        Throws:
        MessageException - if message creation failed. NOTE: Does not auto-return to buffer pool the given direct buffer on thrown exception.
      • createAZRawMessage

        public static RawMessage createAZRawMessage​(Message base_message,
                                                    int padding_mode)
        Create the proper AZ raw message from the given base message.
        Parameters:
        base_message - to create from
        Returns:
        AZ raw message