Я создал EventHub для получения случайных сообщений.Исключение из потока «main» java.lang.NoClassDefFoundError: org/apache/qpid/proton/engine/Extendable
Я просто пытался узнать, могу ли я отправлять сообщения из приложения Java.
Ниже приведен код
package com.hasher.connectedcars.sender;
import java.io.IOException;
import java.nio.charset.*;
import java.util.*;
import java.util.concurrent.ExecutionException;
import com.microsoft.azure.eventhubs.*;
import com.microsoft.azure.servicebus.*;
public class Sender {
public static void main(String[] args) throws ServiceBusException,
ExecutionException, InterruptedException, IOException {
try {
final String namespaceName = "******************";
final String eventHubName = "**************************";
final String sasKeyName = "*******************";
final String sasKey = "*******************";
ConnectionStringBuilder connStr = new ConnectionStringBuilder(
namespaceName, eventHubName, sasKeyName, sasKey);
byte[] payloadBytes = "TEST MESSAGES"
.getBytes("UTF-8");
EventData sendEvent = new EventData(payloadBytes);
EventHubClient ehClient = EventHubClient.createFromConnectionStringSync(connStr.toString());
ehClient.sendSync(sendEvent);
} catch (Exception e) {
e.printStackTrace();
}
}
Я получаю ошибку ниже компиляции из затмения в
EventData sendEvent = new EventData(payloadBytes);
The type org.apache.qpid.proton.message.Message cannot be resolved. It is indirectly referenced from required .class files
========================================================================= Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/qpid/proton/engine/Extendable
Может кто-то момент, если мне не хватает некоторых импорта.
Спасибо,
Срихарша
Вы пропускаете класс зависимостей в пути к классам: Вы должны добавить следующие четыре JAR-файлы из дистрибутив Apache Qpid JMS AMQP 1.0 в Java CLASSPATH при создании и запуске приложений JMS с Service Bus: geronimo-jms_1.1_spec-1.0.jar qpid-amqp-1-0-client- [версия] .jar qpid-amqp-1-0-client-jms- [версия] .jar qpid-amqp-1-0-common- [версия] .jar – Eric