8.3. 处理快速消费者
快速消费者可在使用消息时迅速处理消息。如果您确信消息传递系统中的消费者很快,请考虑将窗口大小设置为 -1。将窗口大小设置为此值允许在客户端上绑定消息缓冲。请谨慎使用此设置。如果使用者无法像接收消息一样快处理消息,则客户端上的内存可能会溢出。
为快速消费者设置窗口大小
以下示例演示了如何在使用 AMQ Core Protocol JMS 客户端时将窗口大小设置为 -1,该客户端是快速消费者的信息。
流程
如果客户端使用 JNDI 来实例化其连接工厂,请将
consumerWindowSize参数作为连接字符串 URL 的一部分。将 URL 存储在 JNDI 上下文环境中。以下示例使用jndi.properties文件来存储 URL。java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory connectionFactory.myConnectionFactory=tcp://localhost:61616?consumerWindowSize=-1如果客户端不使用 JNDI 来实例化其连接工厂,请将值传递给
ActiveMQConnectionFactory.setConsumerWindowSize ()。ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactory(...) cf.setConsumerWindowSize(-1);