Merge pull request #9 from JonasMH/develop

Add OnConnect/Disconnect to MqttConService
JonasMH · Jun 9, 2022 · d635f31 · d635f31
2 parents 561d7ef + 6f98a3f
commit d635f31
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/ToMqttNet/MqttConnectionService.cs b/src/ToMqttNet/MqttConnectionService.cs
@@ -17,6 +17,8 @@ public class MqttConnectionService : BackgroundService, IMqttConnectionService
 		private IManagedMqttClient? _mqttClient;
 
 		public event EventHandler<MqttApplicationMessageReceivedEventArgs> OnApplicationMessageReceived = null!;
+		public event EventHandler<EventArgs>? OnConnect;
+		public event EventHandler<EventArgs>? OnDisconnect;
 
 		public MqttConnectionService(
 			ILogger<MqttConnectionService> logger,
@@ -57,11 +59,14 @@ await _mqttClient.PublishAsync(
 						.WithTopic($"{MqttOptions.NodeId}/connected")
 						.WithRetainFlag()
 						.Build());
+
+				OnConnect?.Invoke(this, new EventArgs());
 			});
 
 			_mqttClient.UseDisconnectedHandler((evnt) =>
 			{
 				_logger.LogInformation(evnt.Exception, "Disconnected from mqtt: {reason}", evnt.Reason);
+				OnDisconnect?.Invoke(this, new EventArgs());
 			});
 
 			_mqttClient.UseApplicationMessageReceivedHandler((evnt) =>