private MqttClient mqttClient; public MainWindow() { InitializeComponent(); mqttClient = new MqttClient(IPAddress.Parse(txtConnectionString.Text).ToString()); mqttClient.MqttMsgPublishReceived += client_MqttMsgPublishReceived;//event mqttClient.MqttMsgSubscribed += client_MqttMsgSubscribed;//event } private void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e) { this.Dispatcher.Invoke(() => { lstSubscribe.Items.Add("Recevied..." + System.Text.Encoding.UTF8.GetString(e.Message)); }); } private void client_MqttMsgSubscribed(object sender, MqttMsgSubscribedEventArgs e) { this.Dispatcher.Invoke(() => { lstSubscribe.Items.Add("Topic " + txtTopic.Text); lstSubscribe.Items.Add("Subscribed for id " + e.MessageId); lstSubscribe.Items.Add(" "); }); } private void btnConnect_Click(object sender, RoutedEventArgs e) { try { mqttClient.Connect(Guid.NewGuid().ToString()); lstPublish.Items.Add("*** Connected"); } catch (Exception ex) { lblError.Content = ex.Message.ToString(); } } private void btnSubscribe_Click(object sender, RoutedEventArgs e) { mqttClient.Subscribe(new string[] { txtTopic.Text }, new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE }); }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)