本文整理了Java中org.apache.activemq.artemis.core.server.Queue.resume
方法的一些代码示例,展示了Queue.resume
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.resume
方法的具体详情如下:
包路径:org.apache.activemq.artemis.core.server.Queue
类名称:Queue
方法名:resume
[英]Resumes the delivery of message for the queue. If a queue is resumed, resuming it again will only throw a warning. To check if a queue is resumed, invoke isPaused()
[中]恢复队列的消息传递。如果队列恢复,再次恢复队列只会抛出警告。要检查队列是否已恢复,请调用isPaused()
代码示例来源:origin: apache/activemq-artemis
@Override
public void postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) throws Exception {
for (Queue queue : queues.values()) {
if (!queue.isPersistedPause()) {
queue.resume();
}
}
if (System.getProperty("org.apache.activemq.opt.directblast") != null) {
messageJournal.runDirectJournalBlast();
}
}
代码示例来源:origin: apache/activemq-artemis
@Override
public void resume() {
checkStarted();
clearIO();
try {
queue.resume();
} finally {
blockOnIO();
}
}
代码示例来源:origin: apache/activemq-artemis
queue.resume();
内容来源于网络,如有侵权,请联系作者删除!