TsgcWSPClient_MQTT › Gebeurtenissen › OnMQTTConnect

OnMQTTConnect Gebeurtenis

Wordt geactiveerd nadat CONNACK is ontvangen; rapporteert de Session-vlag, ReasonCode en MQTT 5 ConnectProperties.

Syntaxis

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

Standaardwaarde

—

Opmerkingen

Wordt geactiveerd wanneer de broker de CONNECT bevestigt met een CONNACK. Dit is het eerste moment waarop de MQTT-sessie volledig bruikbaar is — het is veilig om Subscribe/Publish aan te roepen vanuit deze handler. Parameters:

• Session — sessietoestand aan de brokerzijde. Met CleanSession = True moet de broker antwoorden met Session = False. Met CleanSession = False betekent Session = True dat de broker nog steeds opgeslagen toestand had voor deze ClientIdentifier, Session = False betekent dat dit niet het geval was.
• ReasonCode (MQTT 5) — numerieke CONNACK-reden (0 = Succes).
• ReasonName (MQTT 5) — voor mensen leesbare beschrijving van ReasonCode.
• ConnectProperties (MQTT 5) — brokermogelijkheden en onderhandelde limieten: SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod en AuthenticationData.

Voorbeeld

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;

Terug naar gebeurtenissen