27 lines
1.0 KiB
C#
27 lines
1.0 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
|
|
namespace BlubbFish.Utils.IoT.Connector {
|
|
public abstract class ADataBackend {
|
|
|
|
public abstract event MqttMessage MessageIncomming;
|
|
public abstract event MqttMessage MessageSending;
|
|
public delegate void MqttMessage(Object sender, MqttEventArgs e);
|
|
|
|
public static ADataBackend GetInstance(Dictionary<String, String> settings) {
|
|
String object_sensor = "BlubbFish.Utils.IoT.Connector.Data." + Char.ToUpper(settings["type"][0]) + settings["type"].Substring(1).ToLower();
|
|
Type t = null;
|
|
try {
|
|
t = Type.GetType(object_sensor, true);
|
|
} catch (TypeLoadException) {
|
|
throw new ArgumentException("settings.ini: " + settings["type"] + " is not a DataBackend");
|
|
}
|
|
return (ADataBackend)t.GetConstructor(new Type[] { typeof(Dictionary<String, String>) }).Invoke(new Object[] { settings });
|
|
}
|
|
|
|
public abstract void Send(String topic, String data);
|
|
|
|
public abstract void Dispose();
|
|
}
|
|
}
|