8.4. 低速なコンシューマーの対処

手順

• クライアントが JNDI を使用して接続ファクトリーをインスタンス化する場合は、接続文字列 URL の一部として consumerWindowSize パラメーターを含めます。JNDI コンテキスト環境内に URL を格納します。以下の例では、jndi.properties ファイルを使用して URL を格納します。

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

• クライアントが JNDI を使用して接続ファクトリーをインスタンス化しない場合は、値を ActiveMQConnectionFactory.setConsumerWindowSize() に渡します。

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