Клиент MQTT не получает подтверждения после публикации сообщения брокеру - PullRequest
Новая
       14

Клиент MQTT не получает подтверждения после публикации сообщения брокеру

0 голосов
/ 26 июня 2018

Моя проблема в том, что когда я хочу ответить на прибывающее сообщение, я не получаю маркер доставки от брокера, но сообщение прибывает в брокер. Я могу видеть это в журналах. Итак, мой вопрос, как ответить публикацией на входящее сообщение?

Так я делаю, а оно не работает ... 

public void setMqttCallback() {

        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(final Throwable throwable) {
                System.out.println("Lost connection to Broker because of: " + throwable.getMessage());
            }

            @Override
            public void messageArrived(final String topic, final MqttMessage mqttMessage) throws Exception {
                System.out.println("Received on " + topic + ": " + new String(mqttMessage.getPayload()));

                topics = new Topics();

                //Answer to arriving messages (Logic)
                if (topic.equals(topics.getVehicleNavLandmarkInfo(Mqtt.VIN_ID))) {

                    landmarks = new Landmarks();

                    MqttMessage message = new MqttMessage(landmarks.getLandmarks().getBytes());
                    message.setQos(2);

                    System.out.println("Sending on " + topic + ": " + landmarks.getLandmarks());
                    
                    mqttClient.publish(topics.getBackendNavLandsmarks(Mqtt.VIN_ID), message);
                }

                if (topic.equals(topics.getVehicleNavDestination(Mqtt.VIN_ID))) {

                    routing = new Routing(49.0000, 8.0000, "A");

                    MqttMessage message = new MqttMessage(routing.getShortestPath().getBytes());
                    message.setQos(2);

                    System.out.println("Sending on " + topic + ": " + routing.getShortestPath());
                    
                    mqttClient.publish(topics.getBackendNavRoute(Mqtt.VIN_ID), message);
                }
            }

            @Override
            public void deliveryComplete(final IMqttDeliveryToken iMqttDeliveryToken) {
                System.out.println("Delivered Message: " + iMqttDeliveryToken.toString());
            }
        });
    }

1 Ответ

0 голосов
/ 27 июня 2018

Метод messageArrived блокируется, поэтому вы не можете попытаться опубликовать сообщение, используя то же соединение mqttClient. Вам нужно использовать другой поток, который имеет собственное соединение с брокером.

Если это одноразовая ситуация, вы можете запустить новый поток и сделать все в нем, но если ваше приложение будет постоянно публиковать сообщения в поступающих сообщениях, то было бы лучше запустить поток, подключиться к брокеру, а затем подождать для передачи информации из метода messageArrived.

...