2

我在 JBoss 7 的standalone.xml 中设置了一个 hornetQ。

我还创建了一个这样的连接工厂:

<connection-factory name="InVmConnectionFactory">
   <connectors>
       <connector-ref connector-name="in-vm"/>
   </connectors>
   <entries>
       <entry name="java:/ConnectionFactory"/>
   </entries>
   <consumer-max-rate>10</consumer-max-rate>
</connection-factory>

一切都按预期运行,但假设我想在一切运行时实时更改消费者最大速率。我将如何实现这一目标?

我知道我必须使用这种方法

HornetQConnectionFactory.setConsumerMaxRate(int consumerMaxRate) 

但是我如何获得 HornetQConnectionFactory?

编辑:我设法获得了 HornetQConnectionFactory 并设置了最大速率,但这不是在运行时重新加载。我必须停止并重新启动 ConnectionFactory。是否可以在运行时做到这一点?

4

0 回答 0