13.3. 根据注释上的属性过滤 AMQP 消息
在将过期或未提供 AMQP 消息移动到您配置的到期或死信队列之前，代理会将注解和属性应用到消息。客户端可以根据属性或注解创建过滤器，从到期或死信队列中选择要使用的特定消息。
注意
代理应用的属性是 内部 属性。这些属性不公开给客户端供常规使用，但 可以被 过滤器中的客户端指定。
以下是基于消息属性和注解的过滤器示例。根据属性进行过滤是推荐的方法，因为这种方法需要较少的代理处理。
根据消息属性过滤
ConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:5672");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
connection.start();
javax.jms.Queue queue = session.createQueue("my_DLQ");
MessageConsumer consumer = session.createConsumer(queue, "_AMQ_ORIG_ADDRESS='original_address_name'");
Message message = consumer.receive();
根据消息注解过滤
ConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:5672");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
connection.start();
javax.jms.Queue queue = session.createQueue("my_DLQ");
MessageConsumer consumer = session.createConsumer(queue, "\"m.x-opt-ORIG-ADDRESS\"='original_address_name'");
Message message = consumer.receive();
注意
当基于注解消耗 AMQP 消息时，客户端必须将 m. 前缀附加到消息注解中，如上例中所示。
其他资源
- 有关代理应用到过期或未提供 AMQP 消息的注解和属性的更多信息，请参阅 第 4.14 节 “在过期或未提供 AMQP 消息上注解和属性”。
