当前位置: 首页 > 知识库问答 >
问题:

Azure Service Bus Subscription.Close()未按预期工作

沈自珍
2023-03-14

我有一个扩展的应用程序,其中每个实例都连接到一个同名的azure服务总线订阅。最终的结果是只有一个实例可以对任何给定的消息进行操作,因为它们都在监听同一个订阅。

有时,应用程序需要将实例置于空闲状态(service fabric ActiveSecondary replica)。当发生这种情况时,我需要关闭订阅,以便此实例不再接收消息。如果最初有两个实例,一旦其中一个被置于空闲状态,所有消息都应该转到剩余的实例。这一点很重要,以便所有消息都由正确配置的主实例处理。

是我这样做的方式本身就是错误的,还是我的代码中的其他东西导致了这种行为?

共有1个答案

司徒云
2023-03-14

Azure服务总线轨道0和1 SDK不支持CancellationTokens。如果您关闭了您的客户机,消息将不会被处理,那么当它们再次可见时,它们将被另一个竞争实例拾取。这就是MaxLockDurationMaxDeliveryCount对于确保消息有足够的处理尝试来考虑您所描述的等待时间过长的情况非常重要的地方。

 类似资料:
  • 我正在使用spring Roo并希望访问Controller类中的一个bean,该类在ApplicationContext.xml中具有以下配置: 配置类本身是: 在我的Controller中,我认为一个简单的Autowired注释应该可以完成这项工作 在启动过程中,spring在setSkipWeeks方法中打印消息。不幸的是,每当我在控制器中调用config.getSkipWeeks()时,它

  • 当我运行以下程序时,它只打印 然而,从Java 8的equalsIgnoreCase文档中我们发现: 如果以下至少一项为真,则两个字符c1和c2被视为相同的忽略情况: •对每个字符应用java.lang.character.ToUpperCase(char)方法会产生相同的结果 所以我的问题是为什么这个程序不打印 在这两种操作中,都使用了大写字符。

  • 我试图使用来传输我根据前面的问题设置的自定义标头。 我在文件中读到... 我的属性包括:

  • 我正在和selenium一起工作,刮一些数据。 有一个按钮在页面上,我正在点击说“Custom_Cols”。这个按钮为我打开了一个窗口,我可以在那里选择我的列。 我的问题是为什么新窗口上的元素不可见,即使我正在等待元素的可见。补充一下,我已经尝试增加延迟时间,但我还是会偶尔出现这个错误。 我的密码在这里

  • 我正在使用Grails 2.0.1中的springsecurity插件。我的角色层次结构和其他s2属性如下所示。

  • 我有一个问题jsPlumb的deleteEndpoint函数。 我想删除没有任何连接的endpoint。我希望在“连接”时触发此操作,但我认为可能存在一些问题。 但是我把代码移到了“dblclick”,我发现了同样的问题。标记为删除的一个节点被删除,但随后系统中的每个endpoint都被冻结在原地——一旦其元素被拖动,就与该元素断开连接。我不确定是什么原因造成的:以下是相关代码和一些屏幕截图。。。

  • 我知道我做错了什么。但我找不到这里有什么问题。请帮助我正确理解这一点。