Сообщение AMQP Null при использовании маршрутизации Azure IoTHub

У меня есть пользовательская настройка Endpoint + Route на основе TwinChangeEvent в Azure IoT Hub. Я перенаправляю события в очередь служебной шины (также проверенная тема). Я использую Java Service Bus SDK (azure-servicebus-1.1.0.jar) для извлечения сообщений из очереди.

Однако я продолжаю получать NullPointerException в

com.microsoft.azure.servicebusMessageConverter в строке 124 "brokeredMessage.setMessageId(amqpMessage.getMessageId().toString());"

Свойство messageId, похоже, теряется во время маршрутизации.

Есть ли способ обойти это?

Я не вижу нигде в пакете SDK для устройств Azure IoT, где мне нужно было бы установить это после обработки исходного сообщения из Центра Интернета вещей, указывающего на изменение свойства.

Спасибо


person user1116536    schedule 16.11.2017    source источник
comment
Следовали ли вы какому-либо учебнику или образцу?   -  person Rita Han    schedule 17.11.2017
comment
Привет, пользователь 1116536. Вы уверены, что amqpMessage не равен нулю?   -  person Andrey Ilnitsky    schedule 17.11.2017