-
Notifications
You must be signed in to change notification settings - Fork 304
Simple Subscribe Example
James Sutton edited this page Jul 29, 2016
·
1 revision
using System;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
namespace m2mqtt_test_1
{
class Program
{
static void Main(string[] args)
{
System.Console.WriteLine("Hello, World!");
// Create Client instance
MqttClient myClient = new MqttClient("iot.eclipse.org");
// Register to message received
myClient.MqttMsgPublishReceived += client_recievedMessage;
string clientId = Guid.NewGuid().ToString();
myClient.Connect(clientId);
// Subscribe to topic
myClient.Subscribe(new String[] { "/testing" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
System.Console.ReadLine();
}
static void client_recievedMessage(object sender, MqttMsgPublishEventArgs e)
{
// Handle message received
var message = System.Text.Encoding.Default.GetString(e.Message);
System.Console.WriteLine("Message received: " + message);
}
}
}