TsgcWSPClient_MQTT › Événements › OnMQTTConnect

OnMQTTConnect Événement

Se déclenche après réception de CONNACK ; signale l'indicateur Session, le ReasonCode et les ConnectProperties MQTT 5.

Syntaxe

property OnMQTTConnect: TsgcWSMQTTConnectEvent;
// TsgcWSMQTTConnectEvent = procedure(Connection: TsgcWSConnection; const Session: Boolean; const ReasonCode: Integer; const ReasonName: String; const ConnectProperties: TsgcWSMQTTCONNACKProperties) of object

Valeur par défaut

—

Remarques

Déclenché lorsque le courtier confirme le CONNECT avec un CONNACK. C'est le premier moment où la session MQTT est pleinement utilisable — il est sûr d'appeler Subscribe / Publish depuis ce gestionnaire. Paramètres :

• Session — état de session côté broker. Avec CleanSession = True, le broker doit répondre avec Session = False. Avec CleanSession = False, Session = True signifie que le broker avait encore l'état stocké pour ce ClientIdentifier, Session = False signifie qu'il n'en avait pas.
• ReasonCode (MQTT 5) — raison numérique de CONNACK (0 = Succès).
• ReasonName (MQTT 5) — description lisible par l'humain du ReasonCode.
• ConnectProperties (MQTT 5) — capacités du courtier et limites négociées : SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod et AuthenticationData.

Exemple

procedure TForm1.MQTTConnect(Connection: TsgcWSConnection;
  const Session: Boolean; const ReasonCode: Integer;
  const ReasonName: String;
  const ConnectProperties: TsgcWSMQTTCONNACKProperties);
begin
  if ReasonCode <> 0 then
  begin
    Memo1.Lines.Add('Connect rejected: ' + ReasonName);
    Exit;
  end;

  Memo1.Lines.Add(Format('Connected. Session=%s MaxQoS=%d',
    [BoolToStr(Session, True), ConnectProperties.MaximumQoS]));

  // now it is safe to subscribe and publish
  MQTT.Subscribe('sensors/#', mtqsAtLeastOnce);
end;

Retour aux événements