WSO2: адаптер события ввода MQTT не прослушивает - PullRequest
Новая
       38

WSO2: адаптер события ввода MQTT не прослушивает

0 голосов
/ 19 июня 2019

Я использую WSO2 CEP 4.2.0 и создал адаптер события ввода MQTT. Я также создал приемник, который будет получать данные из внешней темы, а затем с помощью потоков, я добавляю несколько логик, и затем то же сообщение будет опубликовано с помощью издателей в другой внешней теме.

Теперь, когда я перезапускаю приложение, я получаю два сообщения: 

INFO {org.wso2.carbon.event.input.adapter.core.internal.InputAdapterRuntime} -  Connecting receiver mqttreceiver_test
INFO {org.wso2.carbon.event.input.adapter.mqtt.internal.util.MQTTAdapterListener} -  MQTT Connection successful

И затем, когда я публикую сообщение от внешнего клиента mqtt, я вижу, что сообщение приходит к получателю события, и после обработки потока сообщение отправляется издателю выходных событий.

Но примерно через 5 минут сообщения больше не принимаются в приемнике событий. Я не получаю никаких сообщений об ошибках также в журналах, но то, что я чувствую, может быть, входной адаптер больше не слушает. Любые предложения или любые рекомендации помогут.

Спасибо

1 Ответ

0 голосов
/ 20 июня 2019

Несколько вещей, которые я мог бы предложить для устранения этой проблемы:

  1. Возможно, поток прерывается, так что событие не достигает издателя выходных событий?Вы можете использовать средство регистрации событий регистратора [1] и регистрировать поток, генерируемый адаптером входных событий MQTT.
  2. Включить журналы отладки для пакета org.wso2.carbon.event.input.adapter.mqtt.internal.util, чтобы вы видели журнал, когда MQTTAdapterListener получает сообщение (см. [2]).Вы можете следовать [3], чтобы включить журналы отладки.
  3. Когда возникнет проблема, создайте дамп потока и посмотрите, запущен ли поток MQTTAdapterListener.

Надеюсь, это поможет вам сузить проблему.

[1] https://docs.wso2.com/display/CEP420/Logger+Event+Publisher

[2] https://github.com/wso2/carbon-analytics-common/blob/v5.1.3/components/event-receiver/event-input-adapters/org.wso2.carbon.event.input.adapter.mqtt/src/main/java/org/wso2/carbon/event/input/adapter/mqtt/internal/util/MQTTAdapterListener.java#L150

[3] https://docs.wso2.com/display/CEP420/Logging

...