diff --git a/README.md b/README.md index 1dc519f..77e763f 100644 --- a/README.md +++ b/README.md @@ -61,95 +61,4 @@ This library is used in the following projects: If you use this library and want to see your project here please let me know. # Examples -## MqttClient - -```csharp -var options = new MqttClientOptions -{ - Server = "localhost" -}; - -var client = new MqttClientFactory().CreateMqttClient(options); -client.ApplicationMessageReceived += (s, e) => -{ - Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###"); - Console.WriteLine($"+ Topic = {e.ApplicationMessage.Topic}"); - Console.WriteLine($"+ Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}"); - Console.WriteLine($"+ QoS = {e.ApplicationMessage.QualityOfServiceLevel}"); - Console.WriteLine($"+ Retain = {e.ApplicationMessage.Retain}"); - Console.WriteLine(); -}; - -client.Connected += async (s, e) => -{ - Console.WriteLine("### CONNECTED WITH SERVER, SUBSCRIBING ###"); - - await client.SubscribeAsync(new List - { - new TopicFilter("#", MqttQualityOfServiceLevel.AtMostOnce) - }); -}; - -client.Disconnected += async (s, e) => -{ - Console.WriteLine("### DISCONNECTED FROM SERVER ###"); - await Task.Delay(TimeSpan.FromSeconds(5)); - - try - { - await client.ConnectAsync(); - } - catch - { - Console.WriteLine("### RECONNECTING FAILED ###"); - } -}; - -try -{ - await client.ConnectAsync(); -} -catch -{ - Console.WriteLine("### CONNECTING FAILED ###"); -} - -Console.WriteLine("### WAITING FOR APPLICATION MESSAGES ###"); - -var messageFactory = new MqttApplicationMessageFactory(); -while (true) -{ - Console.ReadLine(); - - var applicationMessage = messageFactory.CreateApplicationMessage("myTopic", "Hello World", MqttQualityOfServiceLevel.AtLeastOnce); - await client.PublishAsync(applicationMessage); -} -``` - -## MqttServer - -```csharp -var options = new MqttServerOptions -{ - ConnectionValidator = p => - { - if (p.ClientId == "SpecialClient") - { - if (p.Username != "USER" || p.Password != "PASS") - { - return MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword; - } - } - - return MqttConnectReturnCode.ConnectionAccepted; - } -}; - -var mqttServer = new MqttServerFactory().CreateMqttServer(options); -mqttServer.Start(); - -Console.WriteLine("Press any key to exit."); -Console.ReadLine(); - -mqttServer.Stop(); -``` +Please find examples and the documentation at the Wiki of this repository (https://github.com/chkr1011/MQTTnet/wiki). \ No newline at end of file