org.apache.activemq.artemis.core.server.Queue.resume()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(1.1k)|赞(0)|评价(0)|浏览(108)

本文整理了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

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();

相关文章