8.4. 处理慢速消费者

流程

• 如果客户端使用 JNDI 来实例化其连接工厂，在连接字符串 URL 中包括 consumerWindowSize 参数。将 URL 存储在 JNDI 上下文环境中。以下示例使用 jndi.properties 文件存储 URL。

  java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
  connectionFactory.myConnectionFactory=tcp://localhost:61616?consumerWindowSize=0

  Copy to Clipboard Toggle word wrap

• 如果客户端不使用 JNDI 来实例化其连接工厂，请将值传递给 ActiveMQConnectionFactory.setConsumerWindowSize()。

  ConnectionFactory cf =  ActiveMQJMSClient.createConnectionFactory(...)
  cf.setConsumerWindowSize(0);

  Copy to Clipboard Toggle word wrap