Connection timeout error due to high latency on the network

[osmanhadzic]

I try to create a strategy for the fallout messages. When the client loses connection, messages are saved to the local database. After reconnecting the device on the VerneMQ broker, the device resends messages to the VerneMQ broker.

Suppose we have a network with latency of 10 second. I configured latency via:
sudo tc qdisc add dev lo root netem delay 10s
When I call ConnectAsync method, I get an OperationCanceledException exception.

The example below shows I use ConnectAsync with cancelation token. I have also used:

MqttClientOptionsBuilder()
...
.WithTimeout(20000ms) 
...
.Build()

try
            {
                using (var timeoutToken = new CancellationTokenSource(20000))
                {
                    MqttClientConnectResult result = await _client.ConnectAsync(
                    _connectionInfo.GetMqttConnectOptions(),
                    timeoutToken.Token);

                    if (result.ResultCode == MqttClientConnectResultCode.Success)
                    {
                        await CompleteAstarteConnection(result.IsSessionPresent);
                    }
                    else
                    {
                        throw new AstarteTransportException
                        ($"Error connecting to MQTT. Code: {result.ResultCode}");
                    }
                }
            }
            catch (OperationCanceledException)
            {
                Trace.WriteLine("Timeout while connecting.");
            }