TsgcWSPClient_MQTT › Eventos › OnMQTTConnect

OnMQTTConnect Evento

Se dispara después de recibir CONNACK; informa del flag de Session, el ReasonCode y las ConnectProperties de MQTT 5.

Sintaxis

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

Valor Predeterminado

—

Observaciones

Se activa cuando el broker confirma el CONNECT con un CONNACK. Este es el primer momento en que la sesión MQTT es completamente utilizable — es seguro llamar a Subscribe / Publish desde dentro de este manejador. Parámetros:

• Session — estado de sesión en el lado del broker. Con CleanSession = True el broker debe responder con Session = False. Con CleanSession = False, Session = True significa que el broker aún tenía estado almacenado para este ClientIdentifier, Session = False significa que no.
• ReasonCode (MQTT 5) — razón numérica de CONNACK (0 = Éxito).
• ReasonName (MQTT 5) — descripción legible por humanos del ReasonCode.
• ConnectProperties (MQTT 5) — capacidades del broker y límites negociados: SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod y AuthenticationData.

Ejemplo

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;

Volver a Eventos