本文整理了Java中org.apache.activemq.broker.region.Queue.doPageInForDispatch方法的一些代码示例，展示了Queue.doPageInForDispatch的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Queue.doPageInForDispatch方法的具体详情如下：
包路径：org.apache.activemq.broker.region.Queue
类名称：Queue
方法名：doPageInForDispatch

Queue.doPageInForDispatch介绍

暂无

代码示例

代码示例来源：origin: apache/activemq

protected void pageInMessages(boolean force, int maxPageSize) throws Exception {
  doDispatch(doPageInForDispatch(force, true, maxPageSize));
}

代码示例来源：origin: apache/activemq

private void doPageIn(boolean force, boolean processExpired, int maxPageSize) throws Exception {
  PendingList newlyPaged = doPageInForDispatch(force, processExpired, maxPageSize);
  pagedInPendingDispatchLock.writeLock().lock();
  try {
    if (dispatchPendingList.isEmpty()) {
      dispatchPendingList.addAll(newlyPaged);
    } else {
      for (MessageReference qmr : newlyPaged) {
        if (!dispatchPendingList.contains(qmr)) {
          dispatchPendingList.addMessageLast(qmr);
        }
      }
    }
  } finally {
    pagedInPendingDispatchLock.writeLock().unlock();
  }
}

代码示例来源：origin: org.apache.activemq/activemq-broker

protected void pageInMessages(boolean force, int maxPageSize) throws Exception {
  doDispatch(doPageInForDispatch(force, true, maxPageSize));
}

代码示例来源：origin: pierre/meteo

private void doPageIn(boolean force) throws Exception {
  List<QueueMessageReference> newlyPaged = doPageInForDispatch(force);
  pagedInPendingDispatchLock.writeLock().lock();
  try {
    if (pagedInPendingDispatch.isEmpty()) {
      pagedInPendingDispatch.addAll(newlyPaged);
    } else {
      for (QueueMessageReference qmr : newlyPaged) {
        if (!pagedInPendingDispatch.contains(qmr)) {
          pagedInPendingDispatch.add(qmr);
        }
      }
    }
  } finally {
    pagedInPendingDispatchLock.writeLock().unlock();
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

protected void pageInMessages(boolean force, int maxPageSize) throws Exception {
  doDispatch(doPageInForDispatch(force, true, maxPageSize));
}

代码示例来源：origin: org.apache.activemq/activemq-all

protected void pageInMessages(boolean force, int maxPageSize) throws Exception {
  doDispatch(doPageInForDispatch(force, true, maxPageSize));
}

代码示例来源：origin: pierre/meteo

protected void pageInMessages(boolean force) throws Exception {
  doDispatch(doPageInForDispatch(force));
}

代码示例来源：origin: org.apache.activemq/activemq-broker

private void doPageIn(boolean force, boolean processExpired, int maxPageSize) throws Exception {
  PendingList newlyPaged = doPageInForDispatch(force, processExpired, maxPageSize);
  pagedInPendingDispatchLock.writeLock().lock();
  try {
    if (dispatchPendingList.isEmpty()) {
      dispatchPendingList.addAll(newlyPaged);
    } else {
      for (MessageReference qmr : newlyPaged) {
        if (!dispatchPendingList.contains(qmr)) {
          dispatchPendingList.addMessageLast(qmr);
        }
      }
    }
  } finally {
    pagedInPendingDispatchLock.writeLock().unlock();
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

private void doPageIn(boolean force, boolean processExpired, int maxPageSize) throws Exception {
  PendingList newlyPaged = doPageInForDispatch(force, processExpired, maxPageSize);
  pagedInPendingDispatchLock.writeLock().lock();
  try {
    if (dispatchPendingList.isEmpty()) {
      dispatchPendingList.addAll(newlyPaged);
    } else {
      for (MessageReference qmr : newlyPaged) {
        if (!dispatchPendingList.contains(qmr)) {
          dispatchPendingList.addMessageLast(qmr);
        }
      }
    }
  } finally {
    pagedInPendingDispatchLock.writeLock().unlock();
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

private void doPageIn(boolean force, boolean processExpired, int maxPageSize) throws Exception {
  PendingList newlyPaged = doPageInForDispatch(force, processExpired, maxPageSize);
  pagedInPendingDispatchLock.writeLock().lock();
  try {
    if (dispatchPendingList.isEmpty()) {
      dispatchPendingList.addAll(newlyPaged);
    } else {
      for (MessageReference qmr : newlyPaged) {
        if (!dispatchPendingList.contains(qmr)) {
          dispatchPendingList.addMessageLast(qmr);
        }
      }
    }
  } finally {
    pagedInPendingDispatchLock.writeLock().unlock();
  }
}