Merge pull request #8 from JonasMH/develop

Add uuid to instanceId
JonasMH · Mar 27, 2022 · 561d7ef · 561d7ef
2 parents 73c706b + 37a600f
commit 561d7ef
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/ToMqttNet/MqttConnectionService.cs b/src/ToMqttNet/MqttConnectionService.cs
@@ -11,6 +11,7 @@ namespace ToMqttNet
 	public class MqttConnectionService : BackgroundService, IMqttConnectionService
 	{
 		private readonly ILogger<MqttConnectionService> _logger;
+		private string _instanceId = Guid.NewGuid().ToString();
 
 		public MqttConnectionOptions MqttOptions { get; }
 		private IManagedMqttClient? _mqttClient;
@@ -30,7 +31,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
 			var options = new ManagedMqttClientOptionsBuilder()
 				.WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
 				.WithClientOptions(new MqttClientOptionsBuilder()
-					.WithClientId(MqttOptions.ClientId)
+					.WithClientId(MqttOptions.ClientId + "-" + _instanceId)
 					.WithTcpServer(MqttOptions.Server, MqttOptions.Port)
 					.WithWillMessage(
 						new MqttApplicationMessageBuilder()