为什么Apache QPID Broker队列声明参数"x-qpid-dlq-enabled“不能正常工作？
Apache QPID Broker是一个开源的消息代理，用于实现高性能、可靠的消息传递。在使用QPID Broker时，可以通过声明参数"x-qpid-dlq-enabled"来启用死信队列（Dead Letter Queue）。死信队列是一种特殊的队列，用于存储无法被消费者正确处理的消息。
然而，如果参数"x-qpid-dlq-enabled"不能正常工作，可能有以下几个原因：
- 版本兼容性问题：不同版本的QPID Broker可能对参数的支持有所不同。请确保使用的QPID Broker版本与参数的使用方式兼容。可以参考QPID Broker的官方文档或社区讨论来获取相关信息。
- 配置错误：在声明队列时，可能存在配置错误导致参数无法生效。请检查队列声明的代码或配置文件，确保参数的正确设置。可以参考QPID Broker的官方文档或示例代码来了解正确的配置方式。
- 依赖缺失：QPID Broker可能依赖其他组件或插件来实现死信队列的功能。如果缺少相关的依赖项，参数"x-qpid-dlq-enabled"可能无法正常工作。请检查QPID Broker的依赖关系，并确保所有必需的组件都已正确安装和配置。
- Bug或限制：QPID Broker可能存在已知的Bug或功能限制，导致参数"x-qpid-dlq-enabled"无法正常工作。在这种情况下，建议查阅QPID Broker的官方文档、社区讨论或Bug跟踪系统，了解是否存在已知的问题，并查找可能的解决方案或替代方法。
总结起来，如果参数"x-qpid-dlq-enabled"不能正常工作，可能是由于版本兼容性、配置错误、依赖缺失或Bug/限制等原因导致的。建议仔细检查相关配置和依赖项，并参考官方文档和社区资源来解决问题。
相关·内容
1回答
为什么Apache QPID Broker队列声明参数"x-qpid-dlq-enabled“不能正常工作？
apache、amqp、qpid、dead-letter
我正在尝试将Apache QPID Broker (版本7.1.6)作为内存代理中的嵌入式运行，并在代理上声明一个队列，同时将队列声明选项x-qpid-dlq-enabled设置为"true“。 public void createQueues() throws Exception {
//connect to embedded broker running on local host
ConnectionFactory factory = createConnectionFactory();
Connection connection = factory.
浏览 17提问于2019-12-19得票数 0
2回答
将具有相同sessionId的所有消息发送到Azure服务总线队列中的死信队列
azure、queue、azureservicebus、dead-letter
我正在处理一个被配置为FIFO (第一个输入第一输出)的蔚蓝服务总线队列。我处理订单申请的状态如下：“待决”、“接收”和“发送”。因此，我将消息按" sessionId“服务总线选项分组，将orderId设置为sessionId，以便在横向缩放的情况下按顺序处理消息。
到目前为止，它工作得很好，我发现的问题是，当“待定”或“接收”状态中的消息由于超时而失败并进入死信队列时。正确处理“已发送”状态中的消息，然后当支持团队将“待定”或“接收”状态消息重新发送到队列时，将正确地处理该顺序，而不是“已发送”。
我可以想出几种控制这种情况的方法，例如，支持小组在重新处理死信队列中的消息之前查看订
浏览 5提问于2022-07-18得票数 2
回答已采纳
2回答
tsf的1.40.5-Hoxton-Higher版本使用@FeignClient指定url请求失效？
spring cloud、微服务平台 TSF、feign、ribbon、url
tsf由1.23.0-Finchley（对于springboot版本为2.0.7）升级到1.40.5-Hoxton-Higher（对于springboot版本2.3.12）后，原本通过@FeignClient指定url请求的服务失效了（他最终还是会到注册中心里面找，但是这个指定url的服务不注册在注册中心的）
浏览 193提问于2023-09-12
4回答
QPid的Maven存储库
java、maven、qpid
我正在尝试使用QPid作为。Maven被用作构建工具。我无法找到包含QPid的maven存储库，因此构建失败。
问题
有人知道包含qpid的mvn存储库吗？
有解决办法吗？我下载了所有的JAR文件，并试图将它们放在.m2/repository/org/apache/qpid/qpid-common/0.6和.m2/repository/org/apache/qpid/qpid-client/0.6下。
但建筑还是失败了。我想我不太了解maven来解决这个问题。那么，解决办法是什么呢？
浏览 15提问于2010-11-24得票数 1
回答已采纳
3回答
如何在RabbitMQ中设置重试次数？
.net、queue、rabbitmq、consumer
我正在使用RabbitMQ，并且我有一个保存电子邮件消息的队列。我的使用者服务将消息出队并尝试发送它们。如果由于任何原因，我的使用者无法发送消息，我希望将消息重新排队以再次发送。我意识到我可以执行一个basicNack并将requeue标志设置为true，但是，我不想无限期地重新排队消息(例如，如果我们的电子邮件系统崩溃，我不想不断地重新排队未发送的消息)。我想定义一个有限的次数，我可以重新排队要再次发送的消息。但是，当我将其出队并发送nack时，我无法在电子邮件消息对象上设置字段。队列中的消息上不存在已更新的字段。有没有其他方法可以解决这个问题？提前谢谢。
浏览 3提问于2014-04-19得票数 78
回答已采纳
2回答
为什么Azure服务总线队列的配额大小为1GB，没有消息？
queue、message-queue、azureservicebus
我有一些Azure服务总线队列正在达到配额，它们要么是非常小的活动和死信消息，要么是零消息。似乎还有其他既不是“活动的”也不是“死信”的信息。他们是什么?服务总线资源管理器指示队列的下列状态，例如：
服务总线资源管理器中的“消息计数”和“传输DL消息计数”非常高。显然，这些都是使用空间的东西。我无法在服务总线资源管理器中接收/删除它们，也找不到关于如何处理它们的任何信息。
Azure也有类似的报道。什么是“传输DL信息”？
浏览 2提问于2017-01-27得票数 0
回答已采纳
1回答
Spring ``jms:侦听器-容器‘和IBM退出队列
jakarta-ee、ibm-mq、websphere-7、spring-jms
我使用Spring的JMS (v.3.1.2) listener-container，它的JMS connectionFactory来自WebSphere 7的JNDI设置。应用程序正确地处理消息(put/get)，但是MQ队列管理器中设置的备份设置似乎不起作用。
要使消息消耗失败，我对setRollbackOnly()使用spring事务，并且它确实增加了属性“退出计数”，因为我可以看到，随着指向远程队列的"WebSphere MQ资源管理器“，这个数量在增加。
通过阅读一些IBM文档，它描述了IBM客户端需要将坏消息移动到备份队列中。Spring的listener-containe
浏览 2提问于2014-10-03得票数 3
回答已采纳
2回答
通过lambda重新排队接收到的SQS消息
aws-lambda、amazon-sqs
工作原理:使用AWS-SQS SDK for .Net，我能够在消息可见性计时器窗口中接收一批消息并删除单个消息。我也不能做任何事情，并有效地重新排队消息，如果它被重新排队配置的次数，它就会变得死气沉沉。
不起作用的是:我正在尝试使用Lambda做同样的事情。我已经创建了一个触发器，这意味着SQS会触发lambda，向其发送一批消息。当这种情况发生时，这些消息似乎会自动从队列中删除。我无法控制删除单个消息或将其重新排队。
在lambda中抛出异常似乎会使批处理中的所有消息都保留在队列中。有没有一种更优雅的方法来做这件事，还有一种方法是针对单个消息而不是整个批次？
浏览 1提问于2019-03-12得票数 1
1回答
Python芹菜-如果队列不可用，请进行提拔
python、queue、timeout、celery
我在我的芹菜吐露中定义了一条路线：task_routes = {'tasks.add': {'queue': 'calculate'}}
这样，只有特定的工作人员才会运行该任务。我开始工作：celery -A myproj worker -n worker1@%h -Q calculate
然后运行我的任务：add.apply_async((2, 2), time_limit=5)
万事如意。但现在，假设我的工人死了，我试图再次执行我的任务。它永远挂着。Time_limit对我没有任何好处，因为任务永远不会到达它的队列。在这种情况下，我如何定义超
浏览 2提问于2020-05-11得票数 1
回答已采纳
3回答
用于开发和测试的内存amqp
spring-amqp、qpid
我在我的服务中使用兔，但由于限制，我不能在本地下载。为此，我想在内存代理中使用，并且图中的qpic可以工作。我有以下配置，在日志中我可以看到qpid代理启动正常，但当spring boot尝试发送消息时，它无法连接。
@Bean
Broker broker() throws Exception {
org.apache.qpid.server.Broker broker = new org.apache.qpid.server.Broker();
BrokerOptions brokerOptions = new BrokerOptions();
浏览 0提问于2018-08-16得票数 1
1回答
使用Qpid Proton编写Qpid Java代理的简单示例
amqp、qpid
我是AMQP新手，我正在尝试编写一个简单的应用程序，用Qpid Proton Messenger API写入Qpid Java代理。开箱即用的Qpid有四个默认交易所(amq.match、amq.fanout、amq.topic、amq.direct)，一个在5672端口上的AMQP“端口”，带有passwordFile auth povider。为了避免此测试的安全性，我将auth提供程序更改为匿名。
为了给代理写信，我遵循示例。这个例子没有说明如何写入特定的交换或队列，我认为我的问题就在这个领域的某个地方。这是我的瘦身版。
#include <stdio.h>
#include
浏览 2提问于2015-06-17得票数 1
回答已采纳
1回答
Azure函数-写入到表输出绑定时处理错误
javascript、azure、azure-functions
我有一个Azure函数设置。其触发器设置为服务总线队列消息。当函数被触发时，消息会以某种方式进行处理。如果它在处理过程中遇到任何异常，我会处理该错误，并将消息保存在Azure Table Storage set中作为输出绑定，用于日志记录。
我想要处理在向输出绑定写入内容时抛出的任何错误。我该怎么做呢？
错误的详细信息
我在写入输出绑定(表存储)期间遇到的一个错误是某些键的值无法保存。例如，消息中的一个关键字是具有number__类型的值的time。当我写这个数据的时候，我得到一个异常，键的值不能放在Int32数字中。我认为表存储试图在默认情况下将数字转换为Int32，但失败了。为了解决这个问
浏览 47提问于2019-04-08得票数 2
回答已采纳
2回答
在ActiveMQ Artemis中创建每个消费者DLQ
spring-jms、activemq-artemis
我正在使用ActiveMQ消费来自JMS主题的消息。我的消费者正在直接连接到他们的消费者队列的FQQN。如下所示：
jmsTemplate.setDefaultDestinationName("Transactions.Client1::ConsumerA");
broker.xml中的配置是：
<address-setting match="Transactions.*">
<auto-create-dead-letter-resources>true</auto-create-dead-letter-resources&
浏览 7提问于2022-03-04得票数 1
回答已采纳
2回答
Apache Qpid JMS客户端消息生成器卡住，无法传递到队列
jms、amqp、qpid
我正在尝试通过AMQP1.0协议向Qpid代理发送一条消息。该队列名为queue2，并且已在默认的虚拟主机下创建。然而，producer.send(message)永远被卡住了。同样的代码也适用于连接到Azure服务总线。我使用的是qpid-jms-client 0.58。生产者代码是：
Hashtable<String, String> hashtable = new Hashtable<>();
hashtable.put("connectionfactory.myFactoryLookup", protocol + "://" +
浏览 15提问于2021-09-10得票数 0
1回答
使用一个Qpid代理和多个队列
python、qpid
我先解释一下我的情况。想要实现的是，我的服务器上有多个生产者、多个消费者和一个代理。我希望消息是持久的，队列是持久的。我希望有多个不互相干扰的队列。只有一个队列、一个生产者和一个消费者，这已经可以正常工作了。当前代码：
消费者：
from qpid.connection import Connection
from qpid.datatypes import Message, uuid4
from qpid.util import connect
socket = connect('localhost',5672)
connection = Connection(sock=s
浏览 1提问于2013-09-06得票数 0
回答已采纳
1回答
Axon FW 4.6提供了死信队列支持，但在异常情况下是否仍有回滚支持？
axon、dead-letter
我们正在研究使用Axon的新特性，死信队列(DLQ)。在我们以前的应用程序(axon4.5x)中，我们有很多甚至更新预测。默认情况下，发生异常时将重新抛出异常，这将触发数据库更新的回滚。也许不是依靠这种行为的最佳实践(因为它不能回滚所有的东西，比如发送来自事件的电子邮件当然不能被恢复)，这种行为在我们的应用程序中引入DLQ时似乎迷路了，这对我们当前的应用程序流有很大的影响(以前没有更新预测)。这使得升级并不那么容易。是否仍然可以将旧行为(在异常情况下回滚的事务)与DLQ处理一起使用？
我们尝试的是构建一个测试应用程序来测试新的DLQ特性。虽然在出现异常(它们被移动到dlq)时，所有操作看起来都
浏览 6提问于2022-11-07得票数 1
回答已采纳
2回答
Azure服务总线-删除特定消息
c#、azure、azureservicebus
我正在开发一个系统，它将涉及许多数据同步分解成小任务。我将每个小任务添加为Azure服务总线队列中的作业/消息。
我有X个工作者角色，然后检查队列并处理数据。
我不希望队列中有很多消息，因为它的目的是处理一条消息，完成它，然后再重新添加相同的消息，但是时间安排为X分钟。这将给我一个循环来继续处理这些任务。
Azure功能的伟大之处在于它们为您处理所有服务器端的内容，但缺点是有时很难调试或操作数据。
我想要做的是在web接口中显示队列中的消息列表(我使用了PeekBatch)。然后，我希望能够选择一些/所有的消息并删除它们。
如果代码中有一个bug，并且我想要停止某种类型的消息，我可能想要这样做
浏览 1提问于2014-11-20得票数 3
1回答
任务的Ionic3执行失败:app:transformClassesWithDexBuilderForDebug‘
push-notification、ionic3
在过去的两周里，我一直在处理这个问题，我正在用Ionic3构建一个应用程序。一切都很好，直到我安装phonegap推送插件。然后我开始得到这个错误
Execution failed for task ':app:transformClassesWithDexBuilderForDebug'. > com.android.build.api.transform.TransformException: java.lang.IllegalStateExce ption: Dex archives: setting .DEX extension only for .CLASS f
浏览 2提问于2018-03-24得票数 1
4回答
死信队列和退回队列有什么区别？
jakarta-ee、jms、ibm-mq
死信队列和退回队列有什么区别？
在WebSphere MQ术语和应用程序服务器方面。
所有J2EE/JEE应用服务器都有MQ提供程序，它们是否也有死信队列的结构，或者这是特定于WebSphere MQ的东西吗？
我对back out队列的理解如下：
如果MQ在指定的尝试次数后无法将消息传递到目的地，它会将消息移动到退出队列。
我对死信队列不是很清楚。
感谢您的帮助。
浏览 5提问于2009-05-18得票数 21
回答已采纳
1回答
我正在使用C#和.Net Framework1.1(是的，它很旧，但我继承了这些东西，无法转换)。我将消息放在事务性队列中，但大约50%的时间它不会放到队列中。运行workgroup和Windows/XP Professional，并安装所有service packs。我也没有在死信队列中看到任何消息。
你知道该去哪里找吗？
浏览 0提问于2009-02-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
