Commit 3daa756b by Martin Kotula

Use static mqtt client in hub. Getting queue is empty excpetion

parent 4580fe0b
......@@ -13,6 +13,14 @@ namespace Pi.Hub.Api.Controllers
[Route("api/[controller]")]
public class StatusController : Controller
{
static StatusController(){
Client = new MqttClient("test.mosquitto.org");
Client.Connect(Guid.NewGuid().ToString());
}
static MqttClient Client;
[HttpGet]
[Route("[action]")]
public object Now()
......@@ -25,11 +33,11 @@ namespace Pi.Hub.Api.Controllers
public object Write([FromBody]object obj)
{
string serialized = JsonConvert.SerializeObject(obj);
var client = new MqttClient("test.mosquitto.org");
// var client =
string topic = "e1s/iot.challange" ;
client.Connect(Guid.NewGuid().ToString());
client.Publish(topic, Encoding.UTF8.GetBytes(serialized),MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE, false);
client.Disconnect();
// client.Connect(Guid.NewGuid().ToString());
Client.Publish(topic, Encoding.UTF8.GetBytes(serialized));
// client.Disconnect();
return new
{
......
......@@ -29,8 +29,7 @@ namespace Pi.Hub.Api
WebHost
.CreateDefaultBuilder(args)
.UseStartup<Startup>()
// .UseKestrel(opt => opt.Listen(IPAddress.Parse(configuration["PiHub:Address"]), int.Parse(configuration["PiHub:Port"])))
.UseKestrel()
.UseKestrel(opt => opt.Listen(IPAddress.Parse(configuration["PiHub:Address"]), int.Parse(configuration["PiHub:Port"])))
.Build();
}
}
{
"PiHub": {
"Address": "10.0.200.22",
"Address": "10.0.100.8",
"Port": 5000
},
"Logging": {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment