我是Azure Service Bus和apache qpid的新手。我正在尝试使用https://qpid.apache.org/releases/qpid-jms-amqp-0-x-6.3.4/jms-amqp-0-8-book/JMS-Client-0-8-Appendix-Tomcat-JNDI-Integration.html中提到的在Tomcat context.xml中使用AMPConnectionFactory连接Azure服务总线并配置JMS对等缓存复制 pom.xml <dependenc…

2020年1月14日 0条评论 9点热度 阅读全文

我正在使用来自Microsoft门户的以下代码,用于与Azure服务总线主题/订阅之间收发消息。代码运行正常。当我运行2个接收方代码实例时,总线在2个接收方之间分配消息。 10个发送&&接收5个。我只想知道如何在所有接收者中获取所有消息。 public class ServiceBusTopicSender { static final Gson GSON = new Gson(); public static void main(String[] args) throws Exception, S…

2020年1月8日 0条评论 7点热度 阅读全文

我最近开始研究当前在我们的项目中使用的Azure Service Bus模块。当前模型是,我们将消息发送到某个主题,并且该主题具有多个订阅。没有用于订阅的过滤器,订阅者使用它(当前不希望添加过滤器)。 问题:假设有1个主题和3个订阅。发送给主题的消息将广播到所有订阅,并且两个订阅中的应用程序将使用它。第三次订阅的应用程序关闭,该消息未使用。 第三个订阅中的消息发生什么情况,它将在TTL之后发送到Dead Letter Queue有没有办法找出未使用该消息的订阅 解决方案如下: 第三个订阅中的消息发生什么情况,它将在…

2019年4月13日 0条评论 10点热度 阅读全文