Kaa - не работает приложение MongoDB

У меня проблема с отправкой лога на Kaa Server. Я использую Java и Kaa Sandbox. Сначала я создаю приложение на основе документации Kaa. Я создаю правильный SDK и добавляю его в свой проект. Это очень простой код, просто пытающийся отправить лог ниже на сервер Kaa:

{ 
  "type" : "record",
  "name" : "MyLog",
  "namespace" : "ir.ac.kntu",
  "fields" : [ {
    "name" : "data",
    "type" : {
      "type" : "string",
      "avro.java.string" : "String"
    }
 } ],
 "version" : 1,
 "dependencies" : [ ],
 "displayName" : "My Log"
}

Я создаю приложение для ведения журнала MongoDB, как в этом руководстве: Приложение для ведения журнала MongoDb Kaa

как вы можете видеть на картинке (в конце вопроса), приложение успешно запускается и подключается к Kaa-серверу, но метод sendLog не отправляет журнал на сервер. метод реализован так же, как и в предыдущем уроке:

public void sendLog(MyLog log)
{
    System.out.println("Configure the log delivery listener");
    // Configure the log delivery listener
    kaaClient.setLogDeliveryListener(new LogDeliveryListener() {
        @Override
        public void onLogDeliverySuccess(BucketInfo bucketInfo) {
            System.out.println("success");
        }
        @Override
        public void onLogDeliveryFailure(BucketInfo bucketInfo) {
            System.out.println("failure");
        }
        @Override
        public void onLogDeliveryTimeout(BucketInfo bucketInfo) {
            System.out.println("timeout");
        }
    });
    // Push the record to the collector
    System.out.println("Push the record to the collector");
    RecordFuture logDeliveryStatus = kaaClient.addLogRecord(log);
    System.out.println("Get log delivery information");
    // Get log delivery information
    try {
        RecordInfo logDeliveryReport = logDeliveryStatus.get();
        System.out.println(logDeliveryReport.getBucketInfo()+"_____________________");
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (ExecutionException e) {
        e.printStackTrace();
    }
}

Результаты выполнения и отладки приведены ниже (снимок экрана отладки перед входом в блок try)

Запустить вывод

Отладочный вывод

Я не знаю в чем проблема. На самом деле, у моего проекта есть конечная точка Raspberry Pi, я сталкиваюсь с вышеупомянутой проблемой и не могу ее решить. поэтому я упростил свой проект и создал другое приложение просто для проверки журнала, и снова я столкнулся с той же проблемой.

0 ответов

Другие вопросы по тегам