YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-21 04:03:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

Extend UWP test app

Browse Source
This commit is contained in:
Christian Kratky
2017-09-19 23:03:30 +02:00
parent 32473af7c2
commit 51e7cd725e
5 changed files with 191 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Tests/MQTTnet.TestApp.UniversalWindows/MainPage.xaml.cs
+112 -1
View File
@@ -1,9 +1,13 @@
using System;
using System.Text;
using System.Threading.Tasks;
using Windows.UI.Core;
using Windows.UI.Xaml;
using MQTTnet.Core;
using MQTTnet.Core.Client;
using MQTTnet.Core.Diagnostics;
using MQTTnet.Core.Packets;
using MQTTnet.Core.Protocol;
namespace MQTTnet.TestApp.UniversalWindows
{
@@ -22,7 +26,7 @@ namespace MQTTnet.TestApp.UniversalWindows
{
await Trace.Dispatcher.RunAsync(CoreDispatcherPriority.High, () =>
{
var text = $"[{DateTime.Now:O}] [{e.Level}] [{e.Source}] [{e.ThreadId}] [{e.Message}]{Environment.NewLine}";
var text = $"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] [{e.Level}] [{e.Source}] [{e.ThreadId}] [{e.Message}]{Environment.NewLine}";
if (e.Exception != null)
{
text += $"{e.Exception}{Environment.NewLine}";
@@ -60,5 +64,112 @@ namespace MQTTnet.TestApp.UniversalWindows
Trace.Text += exception + Environment.NewLine;
}
}
private async void Publish(object sender, RoutedEventArgs e)
{
if (_mqttClient == null)
{
return;
}
try
{
var qos = MqttQualityOfServiceLevel.AtMostOnce;
if (QoS1.IsChecked == true)
{
qos = MqttQualityOfServiceLevel.AtLeastOnce;
}
if (QoS2.IsChecked == true)
{
qos = MqttQualityOfServiceLevel.ExactlyOnce;
}
var payload = new byte[0];
if (Text.IsChecked == true)
{
payload = Encoding.UTF8.GetBytes(Payload.Text);
}
if (Base64.IsChecked == true)
{
payload = Convert.FromBase64String(Payload.Text);
}
var message = new MqttApplicationMessage(
Topic.Text,
payload,
qos,
Retain.IsChecked == true);
await _mqttClient.PublishAsync(message);
}
catch (Exception exception)
{
Trace.Text += exception + Environment.NewLine;
}
}
private async void Disconnect(object sender, RoutedEventArgs e)
{
try
{
await _mqttClient.DisconnectAsync();
}
catch (Exception exception)
{
Trace.Text += exception + Environment.NewLine;
}
}
private void Clear(object sender, RoutedEventArgs e)
{
Trace.Text = string.Empty;
}
private async void Subscribe(object sender, RoutedEventArgs e)
{
if (_mqttClient == null)
{
return;
}
try
{
var qos = MqttQualityOfServiceLevel.AtMostOnce;
if (SubscribeQoS1.IsChecked == true)
{
qos = MqttQualityOfServiceLevel.AtLeastOnce;
}
if (SubscribeQoS2.IsChecked == true)
{
qos = MqttQualityOfServiceLevel.ExactlyOnce;
}
await _mqttClient.SubscribeAsync(new TopicFilter(SubscribeTopic.Text, qos));
}
catch (Exception exception)
{
Trace.Text += exception + Environment.NewLine;
}
}
private async void Unsubscribe(object sender, RoutedEventArgs e)
{
if (_mqttClient == null)
{
return;
}
try
{
await _mqttClient.UnsubscribeAsync(SubscribeTopic.Text);
}
catch (Exception exception)
{
Trace.Text += exception + Environment.NewLine;
}
}
}
}