anchor.diff:      begin
         Result := False;
   
  -      FH := FixedHeader(TMQTTMessageType.PUBLISH, 0, 0, Ord(Retain));
  +      FH := FixedHeader(MQTT.PUBLISH, 0, 0, Ord(Retain));
         VH := VariableHeaderPublish(Topic);
         SetLength(Payload, 0);
         AppendArray(Payload, StrToBytes(sPayload, false));
  
positive.code:       VH: TBytes;
        Payload: TUTF8Text;
      begin
        FH := FixedHeader(TMQTTMessageType.SUBSCRIBE, 0, 1, 0);
        VH := VariableHeaderSubscribe;
        Result := (FMessageID - 1);
        SetLength(Payload, 0);
  
negative.code:       Result := False;
  
        SetLength(Data, 2);
        FH := FixedHeader(MQTT.PINGREQ, 0, 0, 0);
        RL := 0;
        Data[0] := FH;
        Data[1] := RL;
  