Class MQTTWireFormat

  • All Implemented Interfaces:

    public class MQTTWireFormat
    extends Object
    implements WireFormat
    Implements marshalling and unmarsalling the MQTT protocol.
    • Constructor Detail

      • MQTTWireFormat

        public MQTTWireFormat()
    • Method Detail

      • setVersion

        public void setVersion​(int version)
        Specified by:
        setVersion in interface WireFormat
        version - the version of the wire format
      • getVersion

        public int getVersion()
        Specified by:
        getVersion in interface WireFormat
        the version of the wire format
      • getMaxFrameSize

        public int getMaxFrameSize()
        the maximum number of bytes a single MQTT message frame is allowed to be.
      • setMaxFrameSize

        public void setMaxFrameSize​(int maxFrameSize)
        Sets the maximum frame size for an incoming MQTT frame. The protocl limit is 256 megabytes and this value cannot be set higher.
        maxFrameSize - the maximum allowed frame size for a single MQTT frame.
      • getConnectAttemptTimeout

        public long getConnectAttemptTimeout()
        the timeout value used to fail a connection if no CONNECT frame read.
      • setConnectAttemptTimeout

        public void setConnectAttemptTimeout​(long connectTimeout)
        Sets the timeout value used to fail a connection if no CONNECT frame is read in the given interval.
        connectTimeout - the connection frame received timeout value.