文字列を 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 = new EventData(payloadBytes);
org.apache.qpid.proton.message.Message のクラス ファイルが見つかりません
誰が考えられる問題を教えてもらえますか??