xljiulang / paho.mqttdotnet Goto Github PK

            client.OnConnectionLost += async (sender) =>
            {
                var mqClient = sender as MqttClient;

                Log4NetUtil.Info("OnConnectionLost", new Dictionary<string, object> { { "mqClientIsConnected", mqClient.IsConnected }});

                ConnectError connectResult = ConnectError.NotAuthorized;

                do
                {
                    try
                    {
                        connectResult = await mqClient.ReConnectAsync();

                        Log4NetUtil.Info("ReConnectAsync", new Dictionary<string, object>
                        {
                            { "ConnectResult",connectResult},
                            { "mqClientIsConnected", mqClient.IsConnected }
                        });

                        await mqClient.SubscribeAsync(subTopic, MqttQoS.AtMostOnce);

                        Log4NetUtil.Info("SubscribeAsync", new Dictionary<string, object> { });
                    }
                    catch (Exception ex)
                    {
                        Log4NetUtil.Error("ReConnectAsync", new Dictionary<string, object> { { "ex", ex.ToString() } });
                    }
                    await Task.Delay(5000);
                } while (!mqClient.IsConnected && connectResult != ConnectError.ConnectionAccepted);
            };