ActiveMQ-Artemis 2.6使用JMS管理API设置队列死信地址

Question

我试图通过JMS管理API为队列设置死信地址。通过阅读最新的Artemis文档，我似乎可以使用queueControl.setdeadletterAddress（...）来完成此操作方法。请参见https://activemq.apache.org/artemis/docs/latest/management.html并搜索“setdeadletteraddress”。

多谢！

Answer 1

查看QueueControlImpl类代码，很明显，setDeadLetterAddress操作不再存在。ActiveMQServerControlImpl类中名为addAddressSettings的操作确实提供了为队列设置DLA的功能（以及许多其他设置）。

例如：

Queue managementQueue = ActiveMQJMSClient.createQueue("activemq.management");
Queue replyQueue = ActiveMQJMSClient.createQueue("management.reply");

JMSContext context = connectionFactory.createContext();
JMSConsumer consumer = context.createConsumer(replyQueue)) {
JMSProducer producer = context.createProducer();
producer.setJMSReplyTo(replyQueue);

// Using AddressSettings isn't required, but is provided
// for clarity.
AddressSettings settings = new AddressSettings()
        .setDeadLetterAddress(new SimpleString("my.messages.dla"))
        .setMaxDeliveryAttempts(5)
        .setExpiryAddress(new SimpleString("ExpiryAddress"))
        .setExpiryDelay(-1L) // No expiry
        .setLastValueQueue(false)
        .setMaxSizeBytes(-1) // No max
        .setPageSizeBytes(10485760)
        .setPageCacheMaxSize(5)
        .setRedeliveryDelay(500)
        .setRedeliveryMultiplier(1.5)
        .setMaxRedeliveryDelay(2000)
        .setRedistributionDelay(1000)
        .setSendToDLAOnNoRoute(true)
        .setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE)
        .setSlowConsumerThreshold(-1)  // No slow consumer checking
        .setSlowConsumerCheckPeriod(1000)
        .setSlowConsumerPolicy(SlowConsumerPolicy.NOTIFY)
        .setAutoCreateJmsQueues(true)
        .setAutoDeleteJmsQueues(false)
        .setAutoCreateJmsTopics(true)
        .setAutoDeleteJmsTopics(false)
        .setAutoCreateQueues(true)
        .setAutoDeleteQueues(false)
        .setAutoCreateAddresses(true)
        .setAutoDeleteAddresses(false);

Message m = context.createMessage();
JMSManagementHelper.putOperationInvocation(m, ResourceNames.BROKER, "addAddressSettings",
        "my.messages", 
        settings.getDeadLetterAddress().toString(),
        settings.getExpiryAddress().toString(),
        settings.getExpiryDelay(),
        settings.isLastValueQueue(),
        settings.getMaxDeliveryAttempts(),
        settings.getMaxSizeBytes(),
        settings.getPageSizeBytes(),
        settings.getPageCacheMaxSize(),
        settings.getRedeliveryDelay(),
        settings.getRedeliveryMultiplier(),
        settings.getMaxRedeliveryDelay(),
        settings.getRedistributionDelay(),
        settings.isSendToDLAOnNoRoute(),
        settings.getAddressFullMessagePolicy().toString(),
        settings.getSlowConsumerThreshold(),
        settings.getSlowConsumerCheckPeriod(),
        settings.getSlowConsumerPolicy().toString(),
        settings.isAutoCreateJmsQueues(),
        settings.isAutoDeleteJmsQueues(),
        settings.isAutoCreateJmsTopics(),
        settings.isAutoDeleteJmsTopics(),
        settings.isAutoCreateQueues(),
        settings.isAutoDeleteQueues(),
        settings.isAutoCreateAddresses(),
        settings.isAutoDeleteAddresses());
producer.send(managementQueue, m);

Message response = consumer.receive();
// addAddressSettings returns void but this will also return errors if the
// method or parameters are wrong.
log.info("addAddressSettings Reply: {}", JMSManagementHelper.getResult(response));