Fixing connection reuse in tests

keesschollaart81 · Nov 3, 2018 · 2f11980 · 2f11980
1 parent 19e5813
commit 2f11980
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/CaseOnline.Azure.WebJobs.Extensions.Mqtt/Config/MqttConnectionFactory.cs b/src/CaseOnline.Azure.WebJobs.Extensions.Mqtt/Config/MqttConnectionFactory.cs
@@ -54,6 +54,7 @@ public async Task DisconnectAll()
                 await connection.Value.MqttConnection.StopAsync().ConfigureAwait(false);
                 connection.Value.MqttConnection.Dispose();
             }
+            _mqttConnections.Clear();
         }
 
         private class MqttConnectionEntry