Я пытаюсь отправить строку в EventHub, и я написал этот код:
private static void sendPOST(ValueChangeMessage valueChangeMessage) throws IOException {
try {
// final String namespaceName = ""; //sericebusnamespacename
// final String eventHubName = "";
// final String sasKeyName = "";
// final String sasKey = "";
// ConnectionStringBuilder connStr = new ConnectionStringBuilder(namespaceName, eventHubName, sasKeyName, sasKey);
byte[] payloadBytes = valueChangeMessage.data.get().toString().getBytes(StandardCharsets.UTF_8);
EventData sendEvent = new EventData(payloadBytes);
EventHubClient ehClient = EventHubClient.createFromConnectionStringSync(connStr.toString());
ehClient.sendSync(sendEvent);
}
catch (ServiceBusException ex) {
Logger.getLogger(CatChannel.class.getName()).log(Level.SEVERE, null, ex);
}
}
Но всякий раз, когда я пытаюсь запустить проект из netbeans, он выдает следующую ошибку:
ошибка: не могу получить доступ к сообщению
sendEvent = новые данные события (байты полезной нагрузки);
файл класса для org.apache.qpid.proton.message.Message не найден
Может кто подскажет в чем может быть проблема??