-
Notifications
You must be signed in to change notification settings - Fork 0
/
CoreEngine.cs
48 lines (42 loc) · 1.65 KB
/
CoreEngine.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Runtime.Serialization.Json;
using MQTTnet.Client;
using MQTTnet;
using System.Text;
using MQTTnet.ManagedClient;
namespace FluksoCore
{
class CoreEngine
{
public static async Task GetMessages()
{
var fluksoIP = FluksoConfig.getConfig("FluksoServer:FluksoIP");
var options = new ManagedMqttClientOptionsBuilder()
.WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
.WithClientOptions(new MqttClientOptionsBuilder()
.WithClientId("FluksoCore")
.WithTcpServer(fluksoIP)
.Build())
.Build();
var mqttClient = new MqttFactory().CreateManagedMqttClient();
await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic("/sensor/+/+").Build());
await mqttClient.StartAsync(options);
Console.WriteLine("Starting FluksoCore");
Console.WriteLine($"Listening on {fluksoIP}");
if (FluksoConfig.getConfig("Output:Console") == "true")
{
mqttClient.ApplicationMessageReceived += MessageHandler.ConsoleHandler;
Console.WriteLine("Output Console enabled");
}
if (FluksoConfig.getConfig("Output:EventHubs") == "true")
{
mqttClient.ApplicationMessageReceived += MessageHandler.EventHubsHandler;
Console.WriteLine("Output EventHubs enabled");
}
await Task.Delay(Timeout.Infinite);
}
}
}