TsgcWSPClient_MQTT › Ereignisse › OnMQTTConnect

OnMQTTConnect Ereignis

Wird ausgelöst, nachdem CONNACK empfangen wurde; meldet das Session-Flag, ReasonCode und die MQTT 5 ConnectProperties.

Syntax

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

Standardwert

—

Hinweise

Wird ausgelöst, wenn der Broker das CONNECT mit einem CONNACK bestätigt. Dies ist der erste Moment, in dem die MQTT-Session vollständig nutzbar ist — es ist sicher, Subscribe / Publish innerhalb dieses Handlers aufzurufen. Parameter:

• Session — broker-seitiger Session-Zustand. Bei CleanSession = True muss der Broker mit Session = False antworten. Bei CleanSession = False bedeutet Session = True, dass der Broker noch gespeicherten Zustand für diesen ClientIdentifier hatte, Session = False bedeutet, dass er das nicht hatte.
• ReasonCode (MQTT 5) — numerischer CONNACK-Grund (0 = Erfolg).
• ReasonName (MQTT 5) — menschenlesbare Beschreibung des ReasonCode.
• ConnectProperties (MQTT 5) — Broker-Fähigkeiten und ausgehandelte Grenzwerte: SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod und AuthenticationData.

Beispiel

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;

Zurück zu Ereignissen