1
我试图发送一个字符串到EventHub和我写了这个代码:得到错误信息未发现 - 天青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中的项目,它 给错误如下:
error: cannot access Message
sendEvent = new EventData(payloadBytes);
class file for org.apache.qpid.proton.message.Message not found
任何人都可以告诉我什么是可能的问题?
有人可以在这里分享他的观点吗?仍然在找到sloution –