Akka.net создает пользовательский поток для mqtt - PullRequest
Новая
       36

Akka.net создает пользовательский поток для mqtt

0 голосов
/ 10 января 2019

Мне нужно создать поток akka, используя mqtt.

сценарий использования: сообщения публикуются в канале mqtt, мне нужно получить эти сообщения в виде потока akka.

пример использования приведен ниже. 

          mqttstream.
            .Buffer(50, OverflowStrategy.DropHead)
            .Throttle(1, TimeSpan.FromSeconds(1), 1, ThrottleMode.Shaping)
            .RunForeach((gpsPoint) => {
                Console.WriteLine("actor got gps cordinates");{gpsPoint.Lattitude}, longitude: {gpsPoint.Longitude}");

            }, materializer);

Итак, чтобы закончить, поток akka должен вывести любое сообщение, опубликованное на канале mqtt.

...