Skip to content

Commit

Permalink
Update packages
Browse files Browse the repository at this point in the history
  • Loading branch information
RobertBeekman committed Feb 26, 2024
1 parent 3e49d05 commit b9e2ed0
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 15 deletions.
8 changes: 4 additions & 4 deletions src/Artemis.Plugins.Mqtt/Artemis.Plugins.Mqtt.csproj
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>net7.0</TargetFramework>
<TargetFramework>net8.0</TargetFramework>
<Platforms>x64</Platforms>
<EnableDynamicLoading>true</EnableDynamicLoading>
</PropertyGroup>

<ItemGroup>
<PackageReference Include="ArtemisRGB.UI.Shared" IncludeAssets="compile;build;buildTransitive" Version="1.2023.1017.2" />
<PackageReference Include="MQTTnet" Version="3.0.14-rc5" />
<PackageReference Include="MQTTnet.Extensions.ManagedClient" Version="3.0.14-rc5" />
<PackageReference Include="ArtemisRGB.UI.Shared" IncludeAssets="compile;build;buildTransitive" Version="1.2024.225.6" />
<PackageReference Include="MQTTnet" Version="4.3.3.952" />
<PackageReference Include="MQTTnet.Extensions.ManagedClient" Version="4.3.3.952" />
</ItemGroup>

<ItemGroup>
Expand Down
19 changes: 10 additions & 9 deletions src/Artemis.Plugins.Mqtt/MqttConnector.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,7 @@
using System.Linq;
using System.Threading.Tasks;
using MQTTnet;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Disconnecting;
using MQTTnet.Client.Options;
using MQTTnet.Client;
using MQTTnet.Extensions.ManagedClient;

namespace Artemis.Plugins.Mqtt;
Expand All @@ -21,9 +19,9 @@ public sealed class MqttConnector : IDisposable
public MqttConnector()
{
client = clientFactory.CreateManagedMqttClient();
client.UseApplicationMessageReceivedHandler(OnClientMessageReceived);
client.UseConnectedHandler(OnClientConnected);
client.UseDisconnectedHandler(OnClientDisconnected);
client.ApplicationMessageReceivedAsync += OnClientMessageReceived;
client.ConnectedAsync += OnClientConnected;
client.DisconnectedAsync += OnClientDisconnected;
}

/// <summary>
Expand Down Expand Up @@ -92,20 +90,23 @@ public Task Stop()
return client.StopAsync();
}

private void OnClientMessageReceived(MqttApplicationMessageReceivedEventArgs e)
private Task OnClientMessageReceived(MqttApplicationMessageReceivedEventArgs e)
{
MessageReceived?.Invoke(this, e);
return Task.CompletedTask;
}

private void OnClientConnected(MqttClientConnectedEventArgs e)
private Task OnClientConnected(MqttClientConnectedEventArgs e)
{
IsConnected = true;
Connected?.Invoke(this, e);
return Task.CompletedTask;
}

private void OnClientDisconnected(MqttClientDisconnectedEventArgs e)
private Task OnClientDisconnected(MqttClientDisconnectedEventArgs e)
{
IsConnected = false;
Disconnected?.Invoke(this, e);
return Task.CompletedTask;
}
}
3 changes: 1 addition & 2 deletions src/Artemis.Plugins.Mqtt/MqttModule.cs
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,7 @@
using Artemis.Plugins.Mqtt.DataModels;
using Artemis.Plugins.Mqtt.DataModels.Dynamic;
using MQTTnet;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Disconnecting;
using MQTTnet.Client;
using Serilog;

namespace Artemis.Plugins.Mqtt;
Expand Down

0 comments on commit b9e2ed0

Please sign in to comment.