Azure service bus订阅没有从主题中获得任何消息
共有1个答案
检查有问题的订阅。订阅支持它们自己的DefaultMessageTimeTolive。默认情况下，它被设置为最大值。看看您用来创建订阅的代码，可能是使用queuedescription自定义DefaultMessageTimeToLive和其他值。
另外，启用EnableDeadLetteringOnMessageExpiration以查看消息是否过期。
检查MaxDeliveryCount。如果它太低，并且消息没有被成功处理，传递计数将超过最大值，消息将被删除或被删除。
-
我有一个简单的java制作人，如下所示 我正在尝试读取如下数据 但消费者并没有从Kafka那里读到任何信息。如果我在处添加以下内容 然后消费者开始从题目开始阅读。但是每次消费者重新启动时，它都从我不想要的主题开始读取消息。如果我在启动消费程序时添加了以下配置 然后，它从主题中读取消息，但是如果消费者在处理所有消息之前重新启动，那么它不会读取未处理的消息。 有人可以让我知道出了什么问题，我该如何解决
-
我刚刚注意到，当我在分区中生成单个消息时，我的使用者不会收到它。只有在我在同一分区中生成了更多的消息之后，使用者才会收到它们。我的数设置为 1。 是否有其他一些配置可能会影响这里？ 每个分区都有一个专用的消费者。 相关部件的使用者代码。我的使用者为 定义的不同主题启动多个线程。使用 https://github.com/mmustala/rdkafka-ruby 这是原始消费宝石的叉子。我添加了一
-
我想使用PublishSubject创建一个广播系统，一个后台任务将轮询一些endpoint，并定期使用该主题广播结果。我希望在第一个订阅者订阅主题时开始轮询，并在没有更多订阅者时停止轮询。如果有新订阅者订阅，则应继续轮询。
-
在我们的业务需求中，我们需要将更新传输到分布在全国各地的数千个客户端。问题是，许多这些客户端使用3G网络连接到我们，因此，发生了许多连接/断开连接...我们需要提供的更新是诸如“企业A不能再兑现”或“企业B能够再次兑现”之类的东西，我们正在考虑使用ActiveMQ持久主题来提供这些更新。我的理解是，一旦客户端连接到持久主题，即使他断开连接，每当他回来时，他都会在脱机时收到发送到该主题的消息。最大的
-
我遵循这篇文档来实现上述场景。 那么，有没有人可以建议我如何一次使用多个订阅者从主题中读取消息。
-
我使用SockJS和StompJS，当我在浏览器中打开我的应用程序时，有时它会在连接到websocket之前尝试订阅一些主题。我希望主题订阅等待应用程序连接到websocket。 这就是我实现此代码的原因，我将其称为： 因此，我只在连接状态为时才订阅该主题，并且只有在客户端首次成功连接时才会调用该主题。 我想稍后从主题中取消订阅，所以我需要内部订阅返回的对象，我还需要内部订阅的消息。 我所实现的很