ActiveMQ Blob消息的持久性
共有1个答案
KahaDB不存储BlobMessage的Blob部分。如果您发送带有Blob所在URL的消息，并且该资源关闭，您的接收者将无法访问它，至少在该资源重新联机之前是这样。
-
我有疑问一条消息是否会在主题中持续存在，我从这篇文章中得到了大部分答案。 但是这种情况如何呢？假设代理重新开始，一些发布者已经开始向一个主题发送消息，现在将来一些持久订户将与该主题连接，但是当前没有持久订户，因此在代理重新开始的情况下，发布者到目前为止向该主题发送的所有消息都将丢失。 我尝试了上述情况，确实所有的信息都丢失了。此外，我尝试了这种情况——我有一个活跃的持久订阅者，它能够将消息推送到主
-
消息应答 ack >[danger] noAck: false 手动接收消息模式 async consume() { const ch = await this.app.amqplib.createChannel(); await ch.assertQueue(queueName, { durable: false }); const msg = await new Pro
-
我正在使用网络逻辑10.3。我正在尝试配置一个持久订阅，其中包含由 jdbc 存储（在 Oracle DB 中）支持的持久消息。我有一个主题，MDB 正在作为持久订阅者侦听该主题。在场景-1下：如果我发送消息，它会命中MDB。 在场景2中:我挂起了MDB，希望发送到主题的消息只要不被MDB(它是唯一注册的持久订阅者)使用，就会一直存在。但是当我向主题发送消息时，它短暂地出现在那里，然后就消失了(我
-
我正试图追踪一个客户不能以他们应该的速度读取消息的问题。持久消息被写入队列。有时，GET速率比PUT速率慢，我们会看到消息备份。
-
我们正在评估SNS以满足集成多个应用程序的消息传递需求。我们有一个生产者，它将消息发布到SNS上的多个主题。每个主题有2-5个订阅者。如果订阅者失败（为了维护而关闭），我对每个消费者使用SQS队列的推荐策略有几个问题 是否可以将SNS配置为仅在向订阅者传递消息失败的情况下推送到SQS？转储SQS队列中的所有消息会给使用者在重新启动时分析队列中的所有消息带来问题 欢迎就如何处理订户故障提出任何建议。
-
清理快照存储区中的旧快照很容易：在每次成功的快照之后，参与者都会收到一个，其中包含指示其序列号的元数据，该信息可以用于构造快照，然后被馈送到。 但是，对于持久化消息，没有与等效的方法。因此，不可能知道日志中“last-ish”消息的序号是什么。可以保留持久消息计数的本地缓存并对其进行快照，以用于调用，但这太繁琐了。 附言。当然，选择用于传递到的序号比上面提到的要复杂一点：即使有一种方法可以从日记中