|
@@ -40,11 +40,11 @@ namespace MQTTnet.TestApp.NetCore |
|
|
Console.WriteLine(">> RECEIVED: " + e.ApplicationMessage.Topic); |
|
|
Console.WriteLine(">> RECEIVED: " + e.ApplicationMessage.Topic); |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|
await managedClient.PublishAsync(builder => builder.WithTopic("Step").WithPayload("1")); |
|
|
|
|
|
await managedClient.PublishAsync(builder => builder.WithTopic("Step").WithPayload("2").WithAtLeastOnceQoS()); |
|
|
|
|
|
|
|
|
|
|
|
await managedClient.StartAsync(options); |
|
|
await managedClient.StartAsync(options); |
|
|
|
|
|
|
|
|
|
|
|
await managedClient.PublishAsync(builder => builder.WithTopic("Step").WithPayload("1")); |
|
|
|
|
|
await managedClient.PublishAsync(builder => builder.WithTopic("Step").WithPayload("2").WithAtLeastOnceQoS()); |
|
|
|
|
|
|
|
|
await managedClient.SubscribeAsync(new TopicFilter { Topic = "xyz", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce }); |
|
|
await managedClient.SubscribeAsync(new TopicFilter { Topic = "xyz", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce }); |
|
|
await managedClient.SubscribeAsync(new TopicFilter { Topic = "abc", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce }); |
|
|
await managedClient.SubscribeAsync(new TopicFilter { Topic = "abc", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce }); |
|
|
|
|
|
|
|
|