Я использую mqtt box для публикации сообщения в теме A, а затем оно подписывается и используется в MiNiFi. После этого то же сообщение отправляется в каталог с использованием процессора putfile, а затем издатель использует это сообщение и публикует его в теме B. Подписчик в поле mqtt подписывается на тему B. Но у меня возникла ошибка при публикации сообщения в теме. B.
Ниже приведена ошибка в журнале MiNiFi:[id = 7199a21d-7af7-3e5e-0000-000000000000] Подключение к tcp: // localhost: 1883 потерял org.eclipse.paho.client.mqttv3.MqttException: соединение потеряно на org.eclipse.paho.client.mqttv3.internal. CommsReceiver.run (CommsReceiver.java:181) в java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:511) в java.util.concurrent.FutureTask.run (FutureTask.java:266) в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 201 (ScheduledThreadPoolExecutor.java:180) в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:293) в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java.6lan: 6): 6(Thread.java:748) Причина: java.io.EOFException: пусто в java.io.DataInputStream.readByte (DataInputStream.java:267) в org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessageMessage(MqttInputStream.java:92) at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run (CommsReceiver.java:133) ... опущено 7 общих кадров 2019-11-04 20: 02: 56,280 ОШИБКА [MQTTRec: 9304a3a5-938f-4089-a878-8cb5219d66d6] oanifi.processors.mqtt.PublishMQTT PublishMQTT [id = 7199a21d-7af7-3e5e-0000-0000000 enter code here 00000] Соединение с tcp: // localhost: 1883 потеряно и 1883 потеряно и 1883 потеряноошибка подключения
