Webshpere MQ根据取款计数器将消息重定向至DLQ
WebSphere MQ是IBM提供的一种消息队列中间件，用于在分布式系统中进行可靠的消息传递。它提供了一种异步通信机制，使得应用程序能够以可靠和高效的方式进行消息交换。
根据取款计数器将消息重定向至DLQ的过程如下：
- WebSphere MQ中的消息队列管理器（MQ Manager）会监控一个特定的队列，该队列用于接收应用程序发送的消息。
- 当一个应用程序发送一条消息到队列时，MQ Manager会根据消息的内容进行处理。
- 在这个特定的场景中，MQ Manager会检查消息中的取款计数器。如果计数器的值达到某个阈值，表示取款次数过多，那么MQ Manager会将该消息重定向至死信队列（Dead Letter Queue，DLQ）。
- 死信队列是一个特殊的队列，用于存储无法被正常处理的消息。这些消息可能是因为格式错误、目标队列不存在等原因导致无法被处理。
- 重定向至DLQ后，应用程序可以通过监控DLQ来获取这些无法被处理的消息，并进行相应的处理。
WebSphere MQ的优势包括：
- 可靠性：WebSphere MQ提供了可靠的消息传递机制，确保消息能够安全地传递到目标队列。
- 异步通信：应用程序可以通过将消息发送到队列中，而不需要直接与目标应用程序进行通信，实现解耦和异步通信。
- 可扩展性：WebSphere MQ支持分布式部署，可以在多个服务器上进行消息传递，实现高可用和负载均衡。
- 安全性：WebSphere MQ提供了身份验证、加密和访问控制等安全机制，保护消息的机密性和完整性。
WebSphere MQ的应用场景包括：
- 银行和金融机构：用于处理交易消息，如支付、转账等。
- 电子商务：用于处理订单、库存、物流等消息。
- 电信行业：用于处理短信、彩信、语音信箱等消息。
- 物联网：用于处理传感器数据、设备状态等消息。
- 企业集成：用于不同系统之间的消息传递和数据同步。
腾讯云提供的相关产品是CMQ（Cloud Message Queue），它是一种高可用、高可靠、分布式的消息队列服务，适用于各种场景下的消息通信。CMQ提供了多种消息模型和消息协议，支持多种编程语言和平台。您可以通过以下链接了解更多关于腾讯云CMQ的信息： https://cloud.tencent.com/product/cmq
相关·内容
在异常的情况下，在活动MQ级别上是否有保留消息执行顺序的选项？换句话说，假设我们有一个名为ID=1的对象的内部消息ID=Student_1000信息，例如，该消息由于某种原因在DLQ中失败并输入了DLQ，但在主队列消息ID= 2和消息ID =3中具有与该学生相同的ID (ID=Student_1000)。我们不应该允许这些消息被处理，因为它们包含与内部消息ID =1相同的对象ID信息；理想情况下，它们应该被直接重定向到DLQ，以保持执行顺序，因为如果我们允许这种处理，我们将在执行update时放松执行顺序。请注意，我使用的是Active MQ的消息组。
如何在活动MQ级别上这样做？
非常感谢，
浏览 2提问于2015-09-11得票数 0
我必须将Webshpere MQ 7.1与MQSeries 5.0连接起来。我必须在应用程序级别上的消息压缩和MQ中的本地压缩之间进行选择。然而，我不能连接到MQSeries 5.0并检查它是否支持我关心的东西--压缩和消息完整性。
因此，我的问题是: MQSeries 5.0 (在该特定版本中)是否提供消息压缩和/或确保消息完整性？
浏览 1提问于2012-08-08得票数 1
回答已采纳
1回答
我在WSO2 ESB中配置了Websphere MQ和Active MQ。我想从Websphere获得消息并将其发送到ActiveMQ。当我使用Websphere队列名获取消息时，它将在ActiveMQ中自动创建一个队列，并唱该队列，而不是访问Websphere。如我所述，如何使用两个不同的队列？
从队列读取消息的代理：
<proxy name="read_from_MQ" transports="jms" startOnLoad="true" trace="disable">
<description/
浏览 5提问于2015-07-02得票数 0
回答已采纳
1回答
我开始使用Anypoint MQ Subscribe，Max Redelivery Count设置为2。
应用程序应该在2次交付失败后抛出ANYPOINT-MQ:RETRY_EXHAUSTED异常，但是消息被返回到主队列，并在下一批中再次捕获。
我正在尝试在使用Try范围发送2次失败后，手动将消息放入DLQ中。
知道吗，如何手动将消息放入DLQ中？
浏览 2提问于2020-08-24得票数 2
即使测试通过，死信队列中仍然有很多消息(1运行43 dlq)。这里有一个相关的例子。
Exchange mx.servicestack.dlq
Routing Key mq:Incr.dlq
Redelivered ○
Properties
timestamp: 1413840195
message_id: 887b23b8-1243-4e58-9332-0c6cb3af14c6
reply_to: mq:tmp:916f686feb924d1fb2bfe5b2aa5087d9
priority: 0
delivery_mode: 2
headers:
浏览 1提问于2014-10-20得票数 0
回答已采纳
我正在使用JAX-RPC 1.1为在WAS 6.0上运行的一组应用程序生成服务，通过Websphere MQ进行通信。大型机将向服务发送消息，因此如果由于某种原因消息无法转换为对象(可能是由于EBCDIC- to -ASCII的怪异)，则需要将消息放在死信队列中进行检查。
有没有人知道有没有一种标准的方法来做到这一点(例如，通过提供带有DLQ名称的jms:/ address )，或者是否需要以某种方式手动执行DLQ转发？
浏览 0提问于2009-10-14得票数 1
回答已采纳
我有带有4个JVM的Webshpere集群。JVM1、JVM2、JVM3和JVM4都在使用单队列MGR1。
如果使用jvm1引导地址放入队列中的消息，其他JVM也可以使用它进行处理。
如果在JVM1、JVM2、JVM3和JVM4前面放置负载均衡器，它与point1有什么不同吗？
如果使用网关Mgr3和子队列mgr、Mgr1和Mgr 2的MQ集群并行处理消息的话。
浏览 2提问于2014-07-18得票数 1
1回答
我有两个队列main queue和DLQ。他们每个人都有自己的交易所。这些交换是主题类型。我在主队列中处理消息，当出现问题时，我将它们重定向到DLX。
我有一个dlq队列的问题，当我手动将消息移动到主队列时，它们不想被执行。消息是从默认交换(AMQP默认)手动转发的，路由键具有队列的名称。我认为这是因为不同的路由密钥和交换。如何解决这个问题呢？
浏览 1提问于2021-06-02得票数 0
我用DLQ中的消息数量做了一个测量。为什么是gauge？因为当问题与事件修复时，消息数量不仅会增加，而且会减少。 但是要发现DLQ中有某些东西，应该通知开发人员(没有人总是坐着检查队列，对吗？)。 我对prometheus和警报有点陌生，有没有一种方法可以配置警报，每次Qauege值随着数量的增加而发送警报？谢谢你！！
浏览 23提问于2021-08-12得票数 0
回答已采纳
我的activemq中有一个配置，不将消息转发到.DLQ队列。
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">">
<!--
Tell the dead letter strategy not to process expired messages
浏览 3提问于2022-07-25得票数 0
我想下载webshpere jar文件，其中包含类com.ibm.mq.ese.jmqi.ESEJMQI，因为我的基于WMQ的消息传递应用程序正在查找它。我在我们公司的repo，maven central，在我本地的WMQ安装中找不到它。我在谷歌上看到过一些关于存在一个名为ese.jar的jar的信息，但没有找到它。你知道我在哪能找到它吗？
浏览 2提问于2014-08-18得票数 0
我排了很多队，例如
my.queue.no.1
my.queue.no.2
my.queue.no.3
my.queue.no.4
我想将不成功的消息重定向到DLQ，但我不想将所有队列中的消息混合到一个DLQ中。
有可能有多个DLQ吗？
i.e
my.queue.no.1
my.queue.no.dlq.1
my.queue.no.2
my.queue.no.dlq.2
my.queue.no.3
my.queue.no.dlq.3
my.queue.no.4
my.queue.no.dlq.4
我用的是Artemis 2.16.0
浏览 7提问于2022-05-09得票数 0
回答已采纳
1回答
如何在邮件传递到DLQ时发送电子邮件通知。
我正在做下面的代码
<spring:beans>
<spring:bean id="redeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy">
<spring:property name="maximumRedeliveries" value="5" />
<spring:property name="initialRedelive
浏览 0提问于2015-05-11得票数 0
1回答
我有一个由SQS触发的lambda，但是我希望在较低的环境中禁用事件触发器。
如果还有发布到该SQS的其他部分，那么消息会发生什么情况？在SQS上没有DLQ。消息会在MessageRetentionPeriod启动后消失吗？
浏览 6提问于2021-11-30得票数 0
回答已采纳
想知道在activeMQ服务器中是否有任何配置可以将消息从DLQ重定向到同一服务器上的另一个队列。
例如。
我有一个队列"MAINQUEUE“，其中有很多消息激活了客户端ack，同时处理如果我得到任何异常，消息将按照预期的方式传输到DLQ。但我希望DLQ中的消息在一段时间后被移回MAINQUEUE，即5-10分钟。是否有任何方法可以使它自动完成，或者我必须通过编写代码手动完成。
谢谢FX
浏览 3提问于2015-11-19得票数 3
回答已采纳
1回答
在使用DLQ配置的SQS队列上有一个lambda触发器。
当我的lambda失败时，队列中的原始消息将被重定向到DLQ。现在，我想向这条原始消息中添加更多的信息(比如为什么会出现错误等等)。我知道我不能修改原始消息，但是我看到消息可以有附加的消息属性RequestID, ErrorCode, ErrorMessage。
如何从我的lambda函数(NodeJS)中使用/设置它们？
浏览 0提问于2018-08-17得票数 4
1回答
我正在将我的java项目从兔子MQ迁移到Kafka (出于某些原因)。
然而，我面临一个困难。
在当前工作流中，我将所有消息发布到兔子mq交换，并根据消息的路由键将消息重定向到一个或多个队列。我也想在卡夫卡保留同样的功能。(我知道卡夫卡最初并不适合它，但我想找个解决办法)。
基本上，我想要这样的东西:每当主题接收到消息时，基于消息中的元信息，消息应该被重定向到其他主题集。
实现这一目标的最快方法是什么？我更喜欢python或java解决方案。
谢谢
浏览 1提问于2017-09-05得票数 0
回答已采纳
我是7岁的Webshpere MQ 6 for JMS Application in java。我在连接到队列时遇到了这个错误。com.ibm.msg.client.jms.DetailedJMSSecurityException: JMSWMQ0018:无法连接到连接模式为“Client”、主机名为“172.21.136.72”的队列管理器“”Test_QManager“”。“”检查队列管理器是否已启动，如果以客户机模式运行，则检查是否有侦听器正在运行。有关详细信息，请参阅链接的异常。
原因: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ调
浏览 0提问于2013-08-06得票数 1
回答已采纳
我们已经在WebSphere MQ v7.0.1.9队列管理器中设置了BOTHRESH(5)、BOQNAME(USER.ERR)。
当WebSphere应用服务器v7中容器管理的TX中的MDB回滚TX时，消息将被放置在DLQ中，而不是放置在原始队列中。
我检查了说明TX回滚成功的日志。
有人能帮帮我吗？
浏览 10提问于2012-11-16得票数 2
回答已采纳
我一直在研究Websphere gem，试图连接到RubyWMQ队列，但没有成功。我的最终目标是使用Ruby连接到队列、读取消息和将消息放入队列。我使用过gem作者文档和示例，但也没有成功。目前我已经尝试过了：
queue = WMQ::QueueManager.connect(
:q_mgr_name => 'MYQUEUEMANAGERNAMEHERE',
:exception_on_error => true,
:trace_level => 2,
# :connect_options =&
浏览 1提问于2016-06-01得票数 4
1回答
我试图使用Camel路由器将消息从queue1(死信队列)移动到active MQ中的queue2，间隔时间为5分钟。我正在使用下面的代码来实现这个目标：
public class MessageRouteBuilder extends RouteBuilder {
private static final Logger LOG =
LoggerFactory.getLogger(MessageRouteBuilder.class);
/*
* (non-Javadoc)
*
* @see org.apache
浏览 4提问于2017-11-13得票数 0
队列无法接受大于4 MB的消息，即使在队列管理器、队列、DLQ、SVRCONN和CLNTCONN上将MAXMSGL设置为100 MB，并为应用程序团队提供了更新的通道选项卡。这并没有解决问题(也重新启动了队列管理器)。
应用程序团队正在使用service/job发布消息。
而同一作业能够连接4+ MB的消息并将其发送到运行在不同服务器上的不同队列管理器。
MQ客户端版本: 7.5.0.2 MQ服务器版本: 7.5.0.3
我尝试使用RFHUtil将4+ MB消息发送到队列，但成功了。但不知何故，它无法从应用程序/作业发送消息。
浏览 0提问于2017-04-13得票数 1
从OSB项目中，我以绑定模式连接到IBM Websphere MQ。将消息从Business Service异步发送到MQ队列工作正常，但我一直收到NPE。谁能告诉我我哪里做错了:)和我的建议？我是OSB和MQ的新手。错误如下：
<AdminServer> <[ACTIVE] ExecuteThread: '23' for queue: 'weblogic.kernel.Default (self-tuning)'>
<<WLS Kernel>> <> <d4c01266a9822b8f:-5e
浏览 1提问于2016-05-25得票数 0
1回答
：入站通道适配器与消息驱动适配器
、、、、
我刚开始使用春季集成卡夫卡。我当时正在读取文档，在入站通道适配器和消息驱动的通道适配器之间出现了混淆。有人能解释他们之间的区别吗。同样，卡夫卡的spring集成也有一些错误处理机制，比如amqp/rmq(使用dlq)的spring集成机制。
PS :我们正试图从兔子mq转移到kafka，作为in集成框架中的消息来源。
谢谢,
浏览 4提问于2019-10-05得票数 0
回答已采纳
2回答
我使用的是activemq 5.10，我想为我的所有队列创建一个自定义的死信队列。
我知道activemq本身通过名称ActiveMQ.DLQ提供内置的DLQ，但是我希望我的自定义DLQ保存所有失败的消息。
我也知道我们可以为每个队列创建单独的DLQ，但这不是我想要的。
任何指点都会有帮助，谢谢。
浏览 0提问于2014-11-17得票数 2
回答已采纳
我已经设置了NServiceBus，以便将失败的消息转发到由ServiceControl监视的错误队列中。
这是我的配置：
<section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
<MessageForwardingInCaseOfFaultConfig ErrorQueue="error" />
当我发送
浏览 2提问于2016-03-30得票数 0
回答已采纳
我不熟悉MQ，所以如果我没有正确解释自己，请原谅我。我们在一个队列上收到了一条消息，该消息在使用2110 MQRC_FORMAT_ERROR读取时失败。问题似乎是它没有指定的“格式”，例如我们期待'MQSTR‘。客户端代码(C#)正在捕获MQException并执行MQQueueManager.Backout()，但是消息只是返回到队列，并被客户机再次读取和拒绝。
查看队列，我发现它没有备份队列或退出阈值设置。队列管理器也没有死信队列集。因此，我所做的就是设置DLQ，并将队列的退出队列设置为5，但是消息仍然卡在队列上，正在继续读取和放回。该消息的回传数量目前已接近2000万。
我想让备
浏览 1提问于2013-10-28得票数 0
回答已采纳
我创建了一个程序，根据序列号从死信队列中读取消息，并复制死信消息的内容，并将其作为一个新消息发送到活动队列，其中包含死信消息的内容以及相同的messageId和其他属性。稍后，我还从DLQ中删除了相同的消息。
public static async Task<string> GetDeadLetterMessagesAsync(string connectionString,
string queueName, long seqNum, int countDLQMessages)
{
//creating a service bus client
浏览 22提问于2022-06-03得票数 1
4回答
我的服务使用来自Azure服务总线订阅的消息。我的服务的依赖性下降了一段时间，这导致许多消息最终进入死信队列(DLQ)。现在服务已经恢复，我想重新处理DLQ中的所有消息。如何将所有消息从DLQ移动/重新提交回主队列。
限制：
它有数千条消息，所以手动处理它们是不可行的。
这个话题大约有十个订阅。我不想将消息重新提交到主题，因为这样所有订阅都会接收消息，从而导致双处理。
我不想直接针对DLQ运行服务，因为一些消息被破坏并导致永久错误，即它们将再次出现在DLQ中，这将导致无限循环。此外，断断续续的信息被放回了队列的前面，实际上是饥饿健康的信息，而这些信息是在那些被破坏的信息之后出现的。
浏览 0提问于2018-03-26得票数 3
1回答
我们目前在架构中使用active/备用Amazon (ActiveMQ)代理。我们已经注意到，随着时间的推移，我们的存储量一直在增加，这降低了代理的性能，并导致了长时间的重新启动。目前，我们对每个主题使用VirtualTopics和4个使用者。
我检查了队列，其中没有一个队列有大量挂起的消息。消费者都足够快地抓取信息并处理它们。唯一有大约40,000条消息的队列是DLQ。但是，我们也尝试删除该队列中的消息，所使用的存储空间仍未减少。
我已经接触到亚马逊的支持，但我没有得到一个有用的答案。
我只想了解是否有一种方法可以理解哪些队列/主题占用了存储空间，这样我们就可以清除消息并减少存储，以获得更好
浏览 6提问于2022-11-11得票数 0
1回答
我用DLQ设置了一个spring流，并进行了循环配置，以便从DLQ返回到主队列。
xdbus.s3Test.0-->DLQ-->xdbus.s3Test.0
stream create s3Test --definition "aws-s3-source | log"
stream deploy S3test --properties module.*.consumer.autoBindDLQ=true
为了使它成为一个圆，我必须更改DLQ的配置，从兔子mq管理UI中手动添加这个配置。
x-message-ttl: 30000
x-dead-letter
浏览 2提问于2015-11-12得票数 0
回答已采纳
1回答
有这样一组模块
Front向API发送REST请求。API (RestController)生成correlationId并通过MQ向队列发送消息。根据请求，它通过指定操作代码来路由消息。进程从队列接收消息，然后根据操作代码执行一些处理。。
问题是该进程可以处理大约5分钟的数据(其他外部服务比较慢)。如果响应在1分钟内没有从API发送到Front，它将将请求重新发送到API。
我需要这样做，以便当您收到完全相同的新请求时，旧的请求会给出响应(不管是什么，因为Front没有在等待答案)，并且在MQ队列中发送了新消息，并等待一个答案而不是第一个模块进程。最后一个活动请求应该等待MQ响应，然后
浏览 2提问于2021-01-23得票数 1
我正在一个Azure Workerrole角色上运行一个NServiceBus端点。我现在把所有的诊断信息都发送到表存储。我在DLQ中收到消息，我不明白为什么我没有在我的表存储中记录任何异常。
结果，NSB将异常记录为INFO，这就是为什么我不能轻易地在所有实际的详细日志记录之间发现它们。
在我的示例中，命令处理程序的依赖关系无法解决，因此Autofac抛出一个异常。我完全理解为什么会抛出异常，我只是不明白为什么他们会被记录为信息。这条消息最终出现在我的DLQ中，我只有一个信息跟踪来了解原因。
是否有理由在NSB中以这种方式处理异常？
浏览 2提问于2016-03-30得票数 0
回答已采纳
我有Azure的主要功能应用程序，处理来自服务总线的消息。
如果由于API下降而发生异常，则将消息推入死信队列。
我有另一个天蓝色死神功能应用程序，它不断读取DLQ并将消息推回主队列。
并且主函数应用程序检查api是否下降，然后再将消息推送到DLQ，这应该继续下去，直到API上升，主函数应用程序成功地处理消息为止。
但问题是经过一段时间消息自动清除。
我检查默认的消息存活时间是2小时30分钟，但是消息不能停留这么长时间。当我将消息推回Main时，我认为在死函数应用程序中。在主队列中，消息可能是重复的，但不确定。
在给定的默认消息生存期内，我应该如何将消息保存到DLQ中？
死信功能应用
浏览 8提问于2020-10-01得票数 0
回答已采纳
我希望在特定条件下将消息从DLQ移到Deffered，例如，如果自定义属性"RetryCount“大于5，则必须将其移动到主队列。将消息从DLQ传输到主队列运行良好。但是，在从DLQ读取消息后，我没有找到合适的解决方案来删除队列。我正在使用C#代码。注意:我使用的是主题和订阅模型。
浏览 4提问于2021-12-07得票数 0
2回答
当我运行以下程序时，我总是会收到“消息太长”的错误消息。为什么？
这是消息来源：
#define NAME "/q"
#define SIZE 16
void main()
{
mqd_t mq;
char buffer[SIZE+1];
struct mq_attr attr;
attr.mq_flags = 0;
attr.mq_maxmsg = 10;
attr.mq_msgsize = SIZE;
attr.mq_curmsgs = 0;
mq = mq_open(NAME, O_CREAT | O_RDWR, 0644, &attr);
printf
浏览 5提问于2013-09-01得票数 0
MQ何时抛出'MQJMS1022:未能重定向消息‘？
我们的应用程序(运行在JDK1.5上)连接到MQ7.5。从MQ读取消息时，将引发以下异常。
javax.jms.JMSException: MQJMS1022: failed to redirect message
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:530)
at com.ibm.mq.jms.MQQueueReceiver.receiveAsync(MQQueueReceiver.jav
浏览 1提问于2016-02-04得票数 0
回答已采纳
我希望使用JMX管理工具将消息从DLQ队列移到另一个队列。
通常，我们将使用moveMessages方法的JMSQueueControl接口：
moveMessages(String，String otherQueueName)将与指定筛选器对应的所有消息移动到指定的其他队列。
我的问题是，如何通过以下调用使用此方法：
/org.hornetq:module=JMS，type=Queue，name="DLQ"/moveMessages
浏览 4提问于2017-04-11得票数 2
回答已采纳
3回答
我有一个由两个lambda订阅的SNS(用KMS加密)。我正在尝试向其中一个订阅添加重新驱动策略。有问题的DLQ是加密的。 添加重新驱动策略会给我一个错误:无法检查Amazon SQS队列权限。请确保队列存在，并且您的帐户具有读取队列属性的权限。要允许Amazon SNS主题将消息发送到Amazon SQS队列，您必须创建Amazon SQS队列策略 我已尝试授予SNS对DLQ队列的解密权限。但没那么走运。有什么线索吗？
浏览 23提问于2020-09-02得票数 5
回答已采纳
1回答
如何在中使用默认死信队列的消息？
、、、、
我将默认DLQ配置如下：
spring:
cloud:
stream:
rabbit:
default:
consumer:
auto-bind-dlq: true
republish-to-dlq: true
dead-letter-queue-name: my-dlq
我想使用默认DLQ中的消息，并在业务域中处理它。
如何使用 Stream侦听这些消息？
谢谢
浏览 0提问于2019-09-20得票数 1
回答已采纳
我们正试图将企业中所有的DLQ合并成一个Q(如果您愿意的话是一个Enterprise_DLQ )。我们有各种平台上的QMs -大型机，各种Unix口味- Linux，AIX，Solaris等，Windows，AS/400.其想法是将QM上的DLQ (在QM上设置DEADQ属性)配置为ENTERPRISE_DLQ (集群Q )的属性。企业中的所有QMs都是集群的成员。然而，当我们测试它时，这种方法似乎不起作用。我已经通过建立一个4 QMs的简单集群来测试这个问题。在其中一个QM上，将QRemote定义为不存在的QM和不存在的Q，但定义一个有效的xmitq，并在QMs之间配置requsite SD
浏览 3提问于2012-03-13得票数 2
我测试了两种情况：
系统V消息队列:用msgget()posix消息队列发送1,000,000条消息"hello“，从另一个进程中获取消息:用mq_send()发送1,000,000条消息"hello”，从另一个进程用mq_receive()获取消息
然后，在这两种情况下，我计算了将消息发送到队列的CPU处理时间。
0.8(sec)posix mq推送时间： mq推送时间:1.4(秒) (!)
第五系统代码：
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#incl
浏览 7提问于2019-12-29得票数 2
回答已采纳
我有lambda使用SQS事件作为输入。SQS队列也有一个DLQ。lambda函数调用下游的Restful (调用此操作DoPostToAPI())，我需要确保lambda函数尝试在上调用DoPostToAPI() 至少2次(在消息进入DLQ之前)
为了完成上述要求，我需要设置哪些Lambda重试和SQS重驱策略？
我需要100%确定到达DLQ的消息只是因为它们试图被发送到下游API DoPostToAPI() 2次，并且如果可能的话，由于任何其他原因消息不会到达DLQ。
对我来说，消息只有在尝试操作时才能到达DLQ，而不是出于其他原因(例如，我不希望消息纯粹由于节流而到达DLQ，因为DoPo
浏览 2提问于2020-08-07得票数 0
我们正在向rabbitMQ发送amqp消息，并且正在设置message-ttl属性。如果消息过期，它们将被移动到定义的DLQ。
是否可以将过期消息移动到单独的DLQ，这样它们就不会因为更严重的原因而干扰移动到DLQ的其他消息？
浏览 0提问于2020-02-28得票数 1
2回答
我试图编写一个消息队列实现，这样我的线程就可以交换数据。为了保持简单，队列只负责发送指向内存的指针。只有一个线程可以发送消息，只有一个线程可以读取消息。
struct mq_t表示消息队列。
mq_t.messages是指针的循环缓冲区。
mq_t.send是上一次发送消息的索引。
mq_t.recv是要接收的下一条消息的索引。
我想知道一些事情：
线程安全:我没有使用互斥锁或锁，但我认为代码非常线程安全。这是真的吗？
在代码中，我使用像while (isempty(queue));这样的东西。是否有更好的方法来处理这些事情，比如挂起线程直到内存发生变化？
跨平台:我的代码是依赖于非跨平台代码
浏览 0提问于2013-08-03得票数 6
回答已采纳
我试图创建一个应用程序级错误处理程序，用于处理SCS应用程序中的故障，使用Kafka作为消息代理。我知道SCS已经提供了DLQ功能，但在我的示例中，我希望用自定义包装器类型包装失败的消息(提供失败上下文(源、原因等))。
在中，您可以看到这种场景的两种方法:一种是使用SCS，另一种是直接Spring。(两者都是自动取款机不工作)
根据当前引用()，SCS将允许发布从通道接收的错误消息，但不幸的是，至少对我来说并非如此。尽管应用程序在启动时记录了以下内容
o.s.i.channel.PublishSubscribeChannel : Channel 'application.err
浏览 2提问于2017-11-06得票数 0
回答已采纳
1回答
websphere MQ集群是否可以基于某些MQMD特征将消息路由到不同的队列？
今天，我们使用应用程序从MQ读取消息，并将它们加载到多个MQ进行并行处理(基于DB2表分区以避免争用)。
我们对MQ功能感兴趣，该功能可以将到达MQ/集群的消息路由到不同的目的地。
浏览 0提问于2015-01-14得票数 1
我正在寻找一种使用spring和兔子MQ使用退避策略实现重试的好方法，但是要求侦听器不应该被阻塞(因此它可以自由地处理其他消息)。我在这里看到了一个类似的问题/回答，但它不包括“后退”的解决方案：
我要问的问题是：
默认的spring-retry实现是否在重试时阻塞线程？表示它这样做了。
如果上面的假设是正确的，那么实现一个单独的重试队列(DLQ?)并为每个消息设置一个TTL (假设我们不想为后退间隔阻塞线程)是唯一的方法。
如果我们采用上述方法(DLQ或单独的队列)，那么对于每次重试，难道不需要单独的队列吗？如果我们只使用一个队列进行重试，同一队列将包含从最小重
浏览 0提问于2015-09-16得票数 8
2回答
使用Spring和RabbitMQ，我设置了两个主题--x和dlx，以及两个队列，q和dlq。q被绑定到x，dlq绑定到dlx。dlx被配置为q的死信交换。
当q中的消息被拒绝(带有unqueue)时，它将成功地发送到dlx，然后发送到dlq。
现在，我使用铲子插件将dlq中的死信信息移回q。只要这一次消息处理成功(ack)，此操作就会成功。
但是，如果q中的其中一条铲子消息再次被拒绝，它就会被悄悄丢弃。我希望它能再次发送到DLX dlx。我配置了什么错误，还是我误解了DLX或铲子的概念？
浏览 1提问于2018-04-30得票数 1
回答已采纳
我有一个SQS队列，这个队列的使用者是lambda，未处理的消息被发送到一个死信队列，重驱策略为10。
我的SQS队列的批处理大小为5，是将特定批中的所有消息发送到DLQ，还是只有那些跨越了10重试尝试而没有处理的消息才会被发送到DLQ。
如果一批5中的3条消息被成功处理，那么所有5条都会转到DLQ，还是只有2条没有被处理。
浏览 5提问于2021-04-08得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
