diff --git a/Build/MQTTnet.nuspec b/Build/MQTTnet.nuspec
index 8cc4e3d3..a6c5cb7f 100644
--- a/Build/MQTTnet.nuspec
+++ b/Build/MQTTnet.nuspec
@@ -13,9 +13,13 @@
* [Client] Added support for web socket communication channel (thanks to nowakpiotr)
* [Core] Huge performance optimizations (thanks to JanEggers)
* [Client] Fixed an issue when calling _DisconnectAsync_ and the connection is already closed.
+* [Core] Added several new interfaces
+* [Core] Added a factory for creation of application messages
+* [Core] Fixed issues in connection handling
+* [Client] Fixed issues with subscribing/unsubscribing (breaking change!)
Copyright Christian Kratky 2016-2017
- MQTT MQTTClient MQTTServer MQTTBroker Broker NETStandard IoT InternetOfThings Messaging Queue Hardware Arduino
+ MQTT Message Queue Telemetry Transport MQTTClient MQTTServer Server MQTTBroker Broker NETStandard IoT InternetOfThings Messaging Hardware Arduino Sensor Actuator M2M
@@ -24,7 +28,7 @@
-
+
diff --git a/README.md b/README.md
index 95755a8b..0e31d6e1 100644
--- a/README.md
+++ b/README.md
@@ -80,14 +80,12 @@ client.ApplicationMessageReceived += (s, e) =>
client.Connected += async (s, e) =>
{
- Console.WriteLine("### CONNECTED WITH SERVER ###");
+ Console.WriteLine("### CONNECTED WITH SERVER, SUBSCRIBING ###");
await client.SubscribeAsync(new List
{
new TopicFilter("#", MqttQualityOfServiceLevel.AtMostOnce)
});
-
- Console.WriteLine("### SUBSCRIBED ###");
};
client.Disconnected += async (s, e) =>
@@ -116,17 +114,12 @@ catch
Console.WriteLine("### WAITING FOR APPLICATION MESSAGES ###");
+var messageFactory = new MqttApplicationMessageFactory();
while (true)
{
Console.ReadLine();
- var applicationMessage = new MqttApplicationMessage(
- "A/B/C",
- Encoding.UTF8.GetBytes("Hello World"),
- MqttQualityOfServiceLevel.AtLeastOnce,
- false
- );
-
+ var applicationMessage = messageFactory.CreateApplicationMessage("myTopic", "Hello World", MqttQualityOfServiceLevel.AtLeastOnce);
await client.PublishAsync(applicationMessage);
}
```