4.7. 配置订阅队列
在大多数情况下,不需要手动创建订阅队列,因为协议管理器会在客户端第一次请求订阅地址时自动创建订阅队列。请参阅 第 4.8.3 节 “协议管理器和地址” 了解更多信息。对于持久订阅,生成的队列名称通常是客户端 ID 和地址的串联。
以下小节演示了如何根据需要手动创建订阅队列。
4.7.1. 配置持久订阅队列
当队列配置为持久订阅时,代理会保存任何不活跃订阅者的消息,并在订阅时将它们传送到订阅者。因此,客户端保证在订阅后接收发送到队列的每个消息。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 将
durable
配置元素添加到所选队列中。将值设为true
。<configuration ...> <core ...> ... <address name="my.durable.address"> <multicast> <queue name="q1"> <durable>true</durable> </queue> </multicast> </address> </core> </configuration>
注意因为队列默认是持久的,包括
durable
元素,并将值设为true
并不严格需要创建持久队列。但是,明确包含该元素可让您稍后将队列的行为更改为非持久(如果需要)。
4.7.3. 配置非持久订阅队列
非持久订阅通常由相关协议管理器管理,后者创建和删除临时队列。
但是,如果要手动创建类似非持久订阅队列的队列,您可以在队列上使用 purge-on-no-consumers
属性。当 purge-on-no-consumers
设为 true
时,队列不会开始接收消息,直到消费者连接为止。另外,当最后一个消费者与队列断开连接时,队列将被清除(即,其消息会被删除)。在新消费者连接到队列前,队列不会接收任何进一步的消息。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 为每个所选队列添加
purge-on-no-consumers
属性。将值设为true
。<configuration ...> <core ...> ... <address name="my.non.durable.address"> <multicast> <queue name="orders1" purge-on-no-consumers="true"/> </multicast> </address> </core> </configuration>