【发布时间】：2012-12-24 21:20:58
【问题描述】：
我想在 hornetq 中对 activeMQ 中某个队列的消费者进行节流（对于 jboss，这是通过 mdb 消费者定义上的注释来实现的）。我在activemq的文档中找不到任何类似的东西，我找到的最接近的是这个
consumer.recvDelay 0 ms Pause consumer for recvDelay milliseconds with each message (allows consumer throttling).
来自：http://activemq.apache.org/activemq-performance-module-users-manual.html
但是我找不到如何在 java 中做到这一点。
提前致谢，
问候。
编辑：这是 ActiveMQManager 代码和使用者代码：
public class ActiveMQManager {
private static ActiveMQConnectionFactory CONNECTION_FACTORY;
public static Connection CONNECTION;
public static Session SESSION;
public static Destination TEST_QUEUE;
public static void start() {
try {
CONNECTION_FACTORY = new ActiveMQConnectionFactory("vm://localhost");
CONNECTION = CONNECTION_FACTORY.createConnection();
CONNECTION.start();
SESSION = CONNECTION.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
TestClient testClient = new TestClient();
TEST_QUEUE = SESSION.createQueue("TEST.QUEUE");
MessageConsumer testConsumer = SESSION.createConsumer(TEST_QUEUE);
test.setMessageListener(testClient);
} catch (Exception e) {
}
}
public static void stop() {
try {
// Clean up
SESSION.close();
CONNECTION.close();
} catch (JMSException e) {
log.error(e);
}
}
}
消费者代码非常简单（本例）：
public class TestConsumer implements MessageListener {
@Override
public void onMessage(Message message) {
//Do something with the message
}
}
【问题讨论】：
-
你能发布你的消费者代码/配置吗？
-
好的，我会把它添加到问题中。