//using log4net.Config; //using System; //using System.Collections.Generic; //using System.IO; //using System.Linq; //using System.Text; //using System.Threading; //using uPLibrary.Networking.M2Mqtt.Messages; //#if TRACE //// alias needed due to Microsoft.SPOT.Trace in .Net Micro Framework //// (it's ambiguos with uPLibrary.Networking.M2Mqtt.Utility.Trace) //using MqttUtility = uPLibrary.Networking.M2Mqtt.Utility; //#endif //namespace uPLibrary.Networking.M2Mqtt //{ // class Program // { // private static readonly log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); // static void Main(string[] args) // { // InitLog4Net(); //#if TRACE // MqttUtility.Trace.TraceLevel = MqttUtility.TraceLevel.Verbose | MqttUtility.TraceLevel.Frame; // MqttUtility.Trace.TraceListener = (f, a) => logger.DebugFormat(f, a); //#endif // // create and start broker // MqttBroker broker = new MqttBroker(); // broker.Start(); // //var mqttclt = new MqttClient("127.0.0.1"); // //mqttclt.MqttMsgPublishReceived += mqttmsgrecive; // //mqttclt.Connect("clientID"); // //mqttclt.Subscribe(new string[] { "/mqtt/pos" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE }); // //mqttclt.Publish("/mqtt/pos", Encoding.UTF8.GetBytes("GeTttttt"), MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE, true); // Console.ReadLine(); // broker.Stop(); // } // static void mqttmsgrecive(object sender, MqttMsgPublishEventArgs e) // { // string msgstr = Encoding.UTF8.GetString(e.Message); // // tlb_msg.Text = msgstr; // // string msgtxt = System.Text.ASCIIEncoding.Default.GetString(Convert.FromBase64String(msgstr)); // //sender.txb_msg.Text = msgtxt; // logger.Info(msgstr); // } // private static void InitLog4Net() // { // var logCfg = new FileInfo(AppDomain.CurrentDomain.BaseDirectory + "log4net.config"); // XmlConfigurator.ConfigureAndWatch(logCfg); // } // } //}