2回答
当我使用异步拉取的方式处理消息时，我不会调用message.ack()和message.nack()，而是等待消息确认截止日期，并期望Pub/Sub重新传递此消息。等待超过10秒后，订阅者不会再次收到消息。topicName, messagePayload);
main(); 我正在使用"@google-cloud/pubsub": "^0.19.0", 我预计订阅者将在10秒后的ack截止日期再次收到消息这意味着我的订阅
浏览 25提问于2019-05-29得票数 1
我想知道是否有可能将一条消息保留在队列中，而不会在一次消费一段时间后由activemq重新传递，即一旦消费完消息m1，会话就会关闭。我希望m1在一段时间内不会被activemq重新交付。时间过后，它可以重新交付。向您致敬，Arijit
浏览 1提问于2012-04-17得票数 0
每个队列都有自己的重新传递策略。假设在处理消息时出现异常，Queue 1将重试消息2次，而Queue 2将重试消息3次。Post重试消息将被发送到死信队列。我观察到，当一条消息被发送到VirtualTopic时，它会同时被传递到两个队列。我正面临一个问题，如果两个队列的使用者都不能成功处理消息。发往Queue 1的消息在重试2次后被移至死信队列。我的期望是Queue 2中的消息会在重试3次后死信。但是该消息<
浏览 19提问于2020-07-26得票数 1
1回答
我想知道是否有任何方法可以将消息返回到其在队列中的原始位置。例如，假设我们有这样的排序： A是头部，D是尾部的A-B-C-D。通常，当我们将nack或reject与requeue=true一起使用时，它只是将消息排在当前尾部之后。在这种情况下，当重新排队A时，新的顺序变为B-C-D-A。
浏览 12提问于2019-07-01得票数 0
回答已采纳
我计划使用solace实现重新投递延迟、重新投递计数和死信队列。其想法是，如果消息未被确认5次，则将其放入死信队列。但是，我想将这5次重试分散在一段时间内。我在solace网站上没有看到任何关于重新交付延迟的文档。
我错过了什么吗？这个特性是不存在的吗？或者，有没有类似的东西？
浏览 21提问于2020-05-31得票数 0
当发生异常时，它会挂起，而不是处理下一条消息。在try块中，我使用了connection.ack()方法，在catch块中，我只是记录了异常，因为发送connection.nack()会将消息发送到死信队列。 1)。我尝试做一个发送消息到DLQ的NACK (不需要)。2)。我已经创建了一个长轮询消费者，它在特定时间后取消订阅，并以这种方式再次订阅，我得到了相同的消息。sys.exit(0) obj.execute()
浏览 16提问于2019-05-16得票数 0
如果我的MDB抛出异常，消息将被重新传递。我试图解决的问题是设置邮件重新传递限制。因为消息传递不会停止。超过300次，直到我删除整个部署。我已经在JBOSS中设置了消息重新传递，但我是weblogic的新手，我想单独为这个队列设置重新传递限制。我应该在哪里设置此消息的最大投递次数？
谢谢
浏览 2提问于2016-05-25得票数 1
我目前正在使用GCM从android应用程序中推送和获取数据，但是我发现GCM注册过程非常不可靠，几乎有1/7次我得到的注册id为空。public String RegisID() {
String msg = "";
浏览 3提问于2014-02-01得票数 1
2回答
SNS可以将每个消费者的消息保留固定的时间段。例如，对于移动用户是20分钟，对于SQS是23小时。在那之后会发生什么？据我所知，消息会被丢弃。为什么SNS没有像SQS和Lambda那样的死信队列，而像其他消息系统一样呢？谢谢
浏览 30提问于2019-10-09得票数 0
回答已采纳
我是GCP发布/订阅新手，正在尝试重新发送未确认的消息(ack/nack)。在GCP控制台仪表板的订阅中，我已经提到： ? ); enter code here } 第一次在我的receiveMessage(PubsubMessage消息，AckReplyConsumer消费者)上收到消息，但如果我不确认消息，就不会再次收到消息。但如果发送nack，则会再次发送消息</
浏览 27提问于2021-09-14得票数 0
ErrorVisibilityTimeout设置为30秒，因为我希望在处理失败时立即重新传递消息。但是，在部署时，或者如果一个实例出现故障并被Beanstalk替换，ErrorVisibilityTimeout就不会被接受&当消息确实被重新处理时，它会在飞行中停留10个小时。 我做错了什么？如何实现实例移出/失败后30秒重新投递消息？
浏览 19提问于2020-11-30得票数 0
回答已采纳
在发布/订阅“推送”模型中，文档是这样说的：有没有办法决定在重试时间过后如何处理消息？例如，将其发送到某个错误队列等？
浏览 0提问于2017-02-25得票数 1
1回答
我的用例涉及到一个Lucene文档的索引，然后在以后的多个场合中添加指向这个现有文档的术语，而不需要删除和重新添加每个新术语的整个文档(因为性能原因，而不是保留原始条款)。我的问题是为什么？为什么不可能添加另一个术语来指向现有的文档--从技术上讲:所需要的不只是将现有的文档Id放在该术语的投递列表中。为什么这么难？是否有一些不可改变的统计数据妨碍了我们的工作？
是否有任何解决办法来支持我在现有文档中添加一个术语(索引字段)
浏览 3提问于2012-08-29得票数 9
回答已采纳
1回答
在我发布我的问题之前，我想感谢Gary和Artem帮助我解决我的问题，因为我能够成功地发布从JMS到Kafka的消息，并且事务已经就绪。当kafka关闭前几次重试时，kafka出站适配器抛出异常，消息返回到JMS，然后一次又一次地重试。然而，经过几次重试，即使kafka关机，消息也会从JMS中退出队列，我得到以下例外情况：
2017-07-10 23:27:51.117 ERROR 16116 --- [enerContainer-1" channel="inputToKafka" topic="te
浏览 2提问于2017-07-10得票数 0
回答已采纳
假设我有一个重发策略，可以在每次尝试之间间隔30分钟的情况下重发一条长达10分钟的消息，那么失败的消息到底在哪里呢？我想知道ActiveMQ把这条消息储存在哪里30分钟。
如果我关闭了消费者或者我的消费者已经崩溃，我是否能够在30分钟后恢复消息？
浏览 1提问于2015-04-17得票数 7
回答已采纳
0回答
因此，当应用程序关闭时，消息处于就绪状态。就绪状态的消息数等于(prefetch_count * no。消费者)。
现在的问题是，处于就绪状态的消息会发生什么情况？它会重新投递吗?
浏览 12提问于2017-06-19得票数 0
回答已采纳
我使用IPN模拟器进行了测试，它运行得很好，但自动响应不能正常工作。IPN历史记录提供了适当的详细信息，但数据库未更改。详细信息如下：消息ID20A455865K857272G原始/重新开始事务ID77S48208XN775144R但是当我<em
浏览 1提问于2013-04-17得票数 0
我有一个azure函数，当有新的消息进入服务总线主题时触发。{ }但不管怎样，在执行上述代码后，订阅中的消息计数将变为如何控制消息处理？当任何异常发生时，我们如何使用Abandon使消息变成死信……
我试图在代码之间添加new throw Exception('test')，但它进入捕获，仍然没有消息转发到死信中。
浏览 0提问于2019-08-21得票数 2
有谁能解释一下为什么短信网关会在不合格投递时收钱呢？是的，我知道，有时确认短信发送很难，但即使服务说不能发送，它仍然需要钱。因为那样的话，他们就不会放款了，为什么要快点呢？一周后当他们回答我的时候。一周后，他们回答了为什么短信没有发送。
问题的一部分是如何处理这个问题，因为现在我只看到一个选项，即使用两种不同的服务并跟踪用户是否尝试发送两次短消息并且帐户未被确认，然后使用以前的其他服务。
浏览 4提问于2016-02-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
