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.UNSUBSCRIBE, 0, 0, 0);
        VH := VariableHeaderUnsubscribe;
        Result := (FMessageID - 1);
        SetLength(Payload, 0);
  
negative.code:       VH: TBytes;
        Payload: TUTF8Text;
      begin
        FH := FixedHeader(MQTT.SUBSCRIBE, 0, 1, 0);
        VH := VariableHeaderSubscribe;
        Result := (FMessageID - 1);
        SetLength(Payload, 0);
  