From e23ac4f70301807e13d13206dedb025e26974f9d Mon Sep 17 00:00:00 2001 From: "Krause, Henning" Date: Fri, 28 Aug 2020 19:08:45 +0200 Subject: [PATCH] Removed test program --- AWSTest/AWSTest.csproj | 13 --------- AWSTest/Program.cs | 64 ------------------------------------------ 2 files changed, 77 deletions(-) delete mode 100644 AWSTest/AWSTest.csproj delete mode 100644 AWSTest/Program.cs diff --git a/AWSTest/AWSTest.csproj b/AWSTest/AWSTest.csproj deleted file mode 100644 index d0bdafa6..00000000 --- a/AWSTest/AWSTest.csproj +++ /dev/null @@ -1,13 +0,0 @@ - - - - Exe - net5.0 - - - - - - - - diff --git a/AWSTest/Program.cs b/AWSTest/Program.cs deleted file mode 100644 index e1453d25..00000000 --- a/AWSTest/Program.cs +++ /dev/null @@ -1,64 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Net.Security; -using System.Security.Cryptography.X509Certificates; -using System.Text; -using System.Threading; -using System.Threading.Tasks; -using MQTTnet; -using MQTTnet.Client; -using MQTTnet.Client.Options; -using MQTTnet.Client.Subscribing; -using MQTTnet.Formatter; -using MQTTnet.Protocol; - -namespace AWSTest -{ - class Program - { - static async Task Main(string[] args) - { - var store = new X509Store(StoreName.My, StoreLocation.CurrentUser); - store.Open(OpenFlags.ReadWrite); - var thumbprint = @"b3a132f6db350ec01f557191abbb4436c9192460"; - var cert = store.Certificates.Find(X509FindType.FindByThumbprint, thumbprint, false)[0]; - -// Create a new MQTT client. - var factory = new MqttFactory(); - var mqttClient = factory.CreateMqttClient(); - - MqttClientOptionsBuilderTlsParameters tlsParameters = new MqttClientOptionsBuilderTlsParameters - { - UseTls = true, - Certificates = new [] {cert}, - ApplicationProtocols = new List {new SslApplicationProtocol("x-amzn-mqtt-ca")} - }; - -// Create TCP based options using the builder. - var connectOptions = new MqttClientOptionsBuilder() - .WithClientId("test-1") - .WithCleanSession(false) - .WithTcpServer("a11ycnpbdonxr-ats.iot.eu-central-1.amazonaws.com", 443) - .WithProtocolVersion(MqttProtocolVersion.V311) - .WithTls(tlsParameters) - .Build(); - - var conResult = await mqttClient.ConnectAsync(connectOptions, CancellationToken.None); - Console.Out.WriteLine("Is session present: " + conResult.IsSessionPresent); - - Console.Out.WriteLine(conResult); - mqttClient.UseApplicationMessageReceivedHandler(Handler); - var result = await mqttClient.SubscribeAsync(new MqttClientSubscribeOptions {TopicFilters = new List {new MqttTopicFilter {QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce, Topic = "topic_1"}}}, CancellationToken.None); - - Console.ReadLine(); - - } - - private static Task Handler(MqttApplicationMessageReceivedEventArgs arg) - { - var message = Encoding.UTF8.GetString(arg.ApplicationMessage.Payload); - Console.Out.WriteLine(message); - return Task.CompletedTask; - } - } -}