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, я сталкиваюсь с вышеупомянутой проблемой и не могу ее решить. поэтому я упростил свой проект и создал другое приложение просто для проверки журнала, и снова я столкнулся с той же проблемой.