我已经有基于Azure EventHub的应用程序。现在,我需要编写连接到现有基础结构的java接收器。
现有配置:
事件中心> SomeName>消费者组> SomeGroupName
在管理控制台中,我看不到任何QUEUE或TOPIC定义。分析工作的C#代码,我可以看到集线器名称+组名称足以连接。
我重构了URL,使我可以通过Java进行连接(到目前为止,连接仍然有效)。
amqps://SomeName.servicebus.windows.net
所以我的问题是:
1)当我指定组名而不是队列/ topic时,出现异常The messaging entity 'sb://SomeName.servicebus.windows.net/SomeGroupName' could not be found.
在那里使用的是什么模型而不是队列/主题?
2)如何从Apache-qpid使用此类基础结构?
最佳答案
您是使用在旧门户中创建的事件中心还是使用新门户中创建的事件中心?
EventHub不是消息总线,因此没有队列或主题,这是正确的。
消费者组不是地址的一部分。该地址是使用名称空间和该名称空间中的eventhub的名称构建的。
因此地址变为:
sb://SomeNameSpaceName.servicebus.windows.net/SomeEventHubName
您可以发布您分析过的C#代码吗?由于您已经有一个正在运行的应用程序,也许我们可以锻炼一些差异来阻止它现在开始工作。
关于java - Azure EventHub上的Qpid接收器,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/40597171/