在ActiveMQ Artemis中为每个消费者创建DLQ

Question

我正在使用JMS消费来自ActiveMQ Artemis主题的消息。我的消费者直接连接到他们消费者队列的FQQN。像这样：

jmsTemplate.setDefaultDestinationName("Transactions.Client1::ConsumerA");

而broker.xml中的配置是：

<address-setting match="Transactions.*">
    <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
    <dead-letter-address>Transactions.Retry</dead-letter-address>
</address-setting>

但是，DLQ的名字将会是<代号> DLQ。Transactions.Client1，没有消费者名称。

我需要的是每个消费者都有自己的DLQ。像DLQ.Transactions.Client1.ConsumerA这样的东西。这可能吗？

编辑:

我说的“消费者”，可能(实际上)更像是一个“消费群体”。例如，< code>ConsumerA和< code>ConsumerB是两个完全不同的应用程序，有(可能)多个运行实例，由自己的团队管理。这就是为什么我希望每个人都有不同的DLQ。

Answer 1

贾斯汀·伯特伦的回答可能是大多数人应该做的。如果不是因为每个消费者申请都有不同的死信地址和到期地址的要求，我也会这么做。

在我的例子中，我使用转向器解决了这个问题。

第一，制作人没换。它一直发布到主题<代码>事务。客户端1。

然后，我在broker.xml文件中配置了一个转移：

<divert name="Transactions.Divert">
    <address>Transactions.Client1</address>
    <forwarding-address>Transactions.Client1.ConsumerA</forwarding-address>
    <exclusive>false</exclusive>
</divert>

重要提示:缺点是它不能扩展。如果我有N个客户和M个消费者，我会有N×M个转移。

然后，地址设置更改为（注意匹配属性中的两个星号）：

<address-setting match="Transactions.*.*">
    <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
    <dead-letter-address>Transactions.Retry</dead-letter-address>
</address-setting>

因此，当消息处理失败时，在地址Transactions.Retry将创建一个名为DLQ.Transactions.Client1.ConsumerA的队列。

每个人都很开心，除了运维人员，他将不得不在生产中配置一百多个分流。我希望他的维姆夫没事。

PS:只是一个提示:总是转移到具有相同前缀的地址(在这个例子中是“交易”)。当您必须在生产环境中配置集群时，这将使您的生活变得更加轻松。

Answer 2

不可能将代理配置为自动创建死信队列，该队列的名称包含最初发送消息的队列的名称。如文档中所述，死信队列是根据最初发送消息的地址以及任何配置的前缀和/或后缀来命名的。

但是，消息本身将有一个名为＜code＞_AMQ_ORIG_QUEUE_AMQ_ORIG_QUEUE='ConsumerA'），这样消费者将只接收最初路由到特定队列的消息。这在功能上等同于每个队列有一个死信队列。

不管怎样，你所谓的“消费者的名字”根本不是消费者的名字，至少从经纪人的角度来看不是。它只是队列的名称。

最终，不可能为每个队列配置死信队列。只能为每个地址配置死信队列。无论资源是手动创建的（例如通过broker.xml）还是自动创建的，都是如此。