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

Queue.getMaxBrowsePageSize介绍

暂无

代码示例

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

@Override
public Message[] browse() {
  List<Message> browseList = new ArrayList<Message>();
  doBrowse(browseList, getMaxBrowsePageSize());
  return browseList.toArray(new Message[browseList.size()]);
}

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

pageInMessages(hasBrowsers && getMaxBrowsePageSize() > 0, getMaxPageSize());
} catch (Throwable e) {
  LOG.error("Failed to page in more queue messages ", e);

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

@Override
public Message[] browse() {
  List<Message> browseList = new ArrayList<Message>();
  doBrowse(browseList, getMaxBrowsePageSize());
  return browseList.toArray(new Message[browseList.size()]);
}

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

@Override
public Message[] browse() {
  List<Message> browseList = new ArrayList<Message>();
  doBrowse(browseList, getMaxBrowsePageSize());
  return browseList.toArray(new Message[browseList.size()]);
}

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

@Override
public Message[] browse() {
  List<Message> browseList = new ArrayList<Message>();
  doBrowse(browseList, getMaxBrowsePageSize());
  return browseList.toArray(new Message[browseList.size()]);
}

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

public Message[] browse() {
  List<Message> browseList = new ArrayList<Message>();
  doBrowse(browseList, getMaxBrowsePageSize());
  return browseList.toArray(new Message[browseList.size()]);
}

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

private void addAll(Collection<QueueMessageReference> refs, List<Message> l, int maxBrowsePageSize,
    List<MessageReference> toExpire) throws Exception {
  for (Iterator<QueueMessageReference> i = refs.iterator(); i.hasNext() && l.size() < getMaxBrowsePageSize();) {
    QueueMessageReference ref = i.next();
    if (ref.isExpired()) {
      toExpire.add(ref);
    } else if (l.contains(ref.getMessage()) == false) {
      l.add(ref.getMessage());
    }
  }
}

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

if (browseList.size() < getMaxBrowsePageSize()) {
  messagesLock.writeLock().lock();
  try {

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

pageInMessages(hasBrowsers && getMaxBrowsePageSize() > 0, getMaxPageSize());
} catch (Throwable e) {
  LOG.error("Failed to page in more queue messages ", e);

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

pageInMessages(hasBrowsers && getMaxBrowsePageSize() > 0, getMaxPageSize());
} catch (Throwable e) {
  LOG.error("Failed to page in more queue messages ", e);

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

pageInMessages(hasBrowsers && getMaxBrowsePageSize() > 0, getMaxPageSize());
} catch (Throwable e) {
  LOG.error("Failed to page in more queue messages ", e);