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 信息上的注解和属性”。
