TsgcWSPClient_MQTT › Olaylar › OnMQTTConnect

OnMQTTConnect Olay

CONNACK alındıktan sonra tetiklenir; Session bayrağını, ReasonCode'u ve MQTT 5 ConnectProperties öğelerini raporlar.

Sözdizimi

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

Varsayılan Değer

—

Remarks

Broker, CONNECT'i bir CONNACK ile onayladığında tetiklenir. Bu, MQTT oturumunun tam olarak kullanılabilir hale geldiği ilk andır, bu işleyicinin içinden Subscribe / Publish çağırmak güvenlidir. Parametreler:

• Session — broker tarafı oturum durumu. CleanSession = True ile broker, Session = False ile yanıt vermelidir. CleanSession = False ile, Session = True broker'ın bu ClientIdentifier için hâlâ saklanan durumu olduğu anlamına gelir, Session = False ise olmadığı anlamına gelir.
• ReasonCode (MQTT 5) — sayısal CONNACK nedeni (0 = Başarılı).
• ReasonName (MQTT 5) — ReasonCode'un insan tarafından okunabilir açıklaması.
• ConnectProperties (MQTT 5) — broker yetenekleri ve müzakere edilen limitler: SessionExpiryInterval, ReceiveMaximum, MaximumQoS, RetainAvailable, MaximumPacketSize, AssignedClientIdentifier, TopicAliasMaximum, ReasonString, UserProperties, WildcardSubscriptionAvailable, SubscriptionIdentifiersAvailable, SharedSubscriptionAvailable, ResponseInformation, ServerReference, AuthenticationMethod ve AuthenticationData.

Örnek

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;

Olaylara Dön