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