我在 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。是否可以在运行时做到这一点?