TsgcWSPClient_MQTT › Eventi › OnMQTTConnect

OnMQTTConnect Evento

Viene attivato dopo la ricezione di CONNACK; riporta il flag Session, ReasonCode e le ConnectProperties MQTT 5.

Sintassi

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

Valore predefinito

—

Note

Generato quando il broker riconosce il CONNECT con un CONNACK. Questo è il primo momento in cui la sessione MQTT è completamente utilizzabile — è sicuro chiamare Subscribe / Publish dall'interno di questo gestore. Parametri:

• Session — stato della sessione lato broker. Con CleanSession = True il broker deve rispondere con Session = False. Con CleanSession = False, Session = True significa che il broker disponeva ancora di uno stato memorizzato per questo ClientIdentifier, Session = False significa che non ne disponeva.
• ReasonCode (MQTT 5) — codice CONNACK numerico (0 = Successo).
• ReasonName (MQTT 5) — descrizione leggibile del ReasonCode.
• ConnectProperties (MQTT 5) — capacità del broker e limiti negoziati: SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod e AuthenticationData.

Esempio

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;

Torna agli Eventi