1

我使用JBoss EAP 7.1 (Wildfly)standalone-full.xml并且通过( ActiveMQ )配置队列时遇到问题

在我的 Web 应用程序中，有许多带有属性选择器的 MDB：在 JMS 消息的标头中设置了属性。如果消息没有设置正确的属性（或没有属性），它会在队列中保持阻塞状态，并且不会进入任何 DLQ 或到期队列。为什么是这样？为什么不被消费？我已经设置standalone-full.xml了自定义 DLQ，一个用于与它自己的 MDB 关联的任何队列。是否可以强制此消息进入任何其他队列？

以下是来自的相关 XML standalone-full.xml：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:2.0">
   ...
   <address-setting name="#" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
   <address-setting name="jms.queue.BackEndDelivery" dead-letter-address="jms.queue.BackEndDeliveryUndelivery" expiry-address="jms.queue.ExpiryQueue" redelivery-delay="10000" max-delivery-attempts="5"/>
   <address-setting name="jms.queue.FrontEndDelivery" dead-letter-address="jms.queue.FrontEndDeliveryUndelivery" expiry-address="jms.queue.ExpiryQueue" redelivery-delay="10000" max-delivery-attempts="5"/>
   ...
   <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
   <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
   <jms-queue name="BackEndDelivery" entries="java:jboss/exported/jms/queue/BackEndDelivery"/>
   <jms-queue name="FrontEndDelivery" entries="java:jboss/exported/jms/queue/FrontEndDelivery"/>
   <jms-queue name="BackEndDeliveryUndelivery" entries="java:jboss/exported/jms/queue/BackEndDeliveryUndelivery"/>
   <jms-queue name="FrontEndDeliveryUndelivery" entries="java:jboss/exported/jms/queue/FrontEndDeliveryUndelivery"/>
   ...
</subsystem>

Java EJB 3.0 MDB 注释：

@MessageDriven(activationConfig = {
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "BackEndDelivery"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "Action='BackEndEntryPoint'") }, mappedName = "BackEndDelivery")
@TransactionManagement(TransactionManagementType.BEAN)
4

1 回答 1

2

您所看到的是预期的行为。如果有消息与队列的任何消费者的选择器不匹配，则不会使用该消息。仅当客户端尝试使用该消息并失败 5 次（即您为 设置的值）时，它才会发送到 DLQ max-delivery-attempts。如果消息有过期时间（显然它没有），它只会被发送到 ExpiryQueue。

您可以通过设置地址设置来强制消息具有过期时间expiry-delay，例如：

<address-setting name="jms.queue.BackEndDelivery" dead-letter-address="jms.queue.BackEndDeliveryUndelivery" expiry-address="jms.queue.ExpiryQueue" expiry-delay="5000" redelivery-delay="10000" max-delivery-attempts="5"/>
<address-setting name="jms.queue.FrontEndDelivery" dead-letter-address="jms.queue.FrontEndDeliveryUndelivery" expiry-address="jms.queue.ExpiryQueue" expiry-delay="5000" redelivery-delay="10000" max-delivery-attempts="5"/>

通过设置expiry-delay="5000"，您可以强制将 5 秒内未使用的任何消息发送到 ExpiryQueue。

于 2019-06-05T15:11:41.667 回答