org.apache.activemq.broker.region.Queue.getName()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(121)

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

Queue.getName介绍

暂无

代码示例

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

MDC.put("activemq.destination", getName());
boolean pageInMoreMessages = false;
synchronized (iteratingMutex) {

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

@Override
public synchronized void start() throws Exception {
  started = true;
  super.start();
  if (nonPersistent == null) {
    if (broker.getBrokerService().isPersistent()) {
      nonPersistent = new FilePendingMessageCursor(broker,queue.getName(),this.prioritizedMessages);
    }else {
      nonPersistent = new VMPendingMessageCursor(this.prioritizedMessages);
    }
    nonPersistent.setMaxBatchSize(getMaxBatchSize());
    nonPersistent.setSystemUsage(systemUsage);
    nonPersistent.setEnableAudit(isEnableAudit());
    nonPersistent.setMaxAuditDepth(getMaxAuditDepth());
    nonPersistent.setMaxProducersToAudit(getMaxProducersToAudit());
  }
  nonPersistent.setMessageAudit(getMessageAudit());
  nonPersistent.start();
  persistent.setMessageAudit(getMessageAudit());
  persistent.start();
  pendingCount = persistent.size() + nonPersistent.size();
}

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

flowControlTimeoutTask.setName(getName()+" Producer Flow Control Timeout Task");
flowControlTimeoutTask.start();

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

MDC.put("activemq.destination", getName());
boolean pageInMoreMessages = false;
synchronized (iteratingMutex) {

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

MDC.put("activemq.destination", getName());
boolean pageInMoreMessages = false;
synchronized (iteratingMutex) {

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

MDC.put("activemq.destination", getName());
boolean pageInMoreMessages = false;
synchronized (iteratingMutex) {

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

MDC.put("activemq.destination", getName());
boolean pageInMoreMessages = false;
synchronized (iteratingMutex) {

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

@Override
public synchronized void start() throws Exception {
  started = true;
  super.start();
  if (nonPersistent == null) {
    if (broker.getBrokerService().isPersistent()) {
      nonPersistent = new FilePendingMessageCursor(broker,queue.getName(),this.prioritizedMessages);
    }else {
      nonPersistent = new VMPendingMessageCursor(this.prioritizedMessages);
    }
    nonPersistent.setMaxBatchSize(getMaxBatchSize());
    nonPersistent.setSystemUsage(systemUsage);
    nonPersistent.setEnableAudit(isEnableAudit());
    nonPersistent.setMaxAuditDepth(getMaxAuditDepth());
    nonPersistent.setMaxProducersToAudit(getMaxProducersToAudit());
  }
  nonPersistent.setMessageAudit(getMessageAudit());
  nonPersistent.start();
  persistent.setMessageAudit(getMessageAudit());
  persistent.start();
  pendingCount = persistent.size() + nonPersistent.size();
}

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

@Override
public synchronized void start() throws Exception {
  started = true;
  super.start();
  if (nonPersistent == null) {
    if (broker.getBrokerService().isPersistent()) {
      nonPersistent = new FilePendingMessageCursor(broker,queue.getName(),this.prioritizedMessages);
    }else {
      nonPersistent = new VMPendingMessageCursor(this.prioritizedMessages);
    }
    nonPersistent.setMaxBatchSize(getMaxBatchSize());
    nonPersistent.setSystemUsage(systemUsage);
    nonPersistent.setEnableAudit(isEnableAudit());
    nonPersistent.setMaxAuditDepth(getMaxAuditDepth());
    nonPersistent.setMaxProducersToAudit(getMaxProducersToAudit());
  }
  nonPersistent.setMessageAudit(getMessageAudit());
  nonPersistent.start();
  persistent.setMessageAudit(getMessageAudit());
  persistent.start();
  pendingCount = persistent.size() + nonPersistent.size();
}

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

@Override
public synchronized void start() throws Exception {
  started = true;
  super.start();
  if (nonPersistent == null) {
    if (broker.getBrokerService().isPersistent()) {
      nonPersistent = new FilePendingMessageCursor(broker,queue.getName(),this.prioritizedMessages);
    }else {
      nonPersistent = new VMPendingMessageCursor(this.prioritizedMessages);
    }
    nonPersistent.setMaxBatchSize(getMaxBatchSize());
    nonPersistent.setSystemUsage(systemUsage);
    nonPersistent.setEnableAudit(isEnableAudit());
    nonPersistent.setMaxAuditDepth(getMaxAuditDepth());
    nonPersistent.setMaxProducersToAudit(getMaxProducersToAudit());
  }
  nonPersistent.setMessageAudit(getMessageAudit());
  nonPersistent.start();
  persistent.setMessageAudit(getMessageAudit());
  persistent.start();
  pendingCount = persistent.size() + nonPersistent.size();
}

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

public synchronized void start() throws Exception {
  started = true;
  super.start();
  if (nonPersistent == null) {
    if (broker.getBrokerService().isPersistent()) {
      nonPersistent = new FilePendingMessageCursor(broker,queue.getName(),this.prioritizedMessages);
    }else {
      nonPersistent = new VMPendingMessageCursor(this.prioritizedMessages);
    }
    nonPersistent.setMaxBatchSize(getMaxBatchSize());
    nonPersistent.setSystemUsage(systemUsage);
    nonPersistent.setEnableAudit(isEnableAudit());
    nonPersistent.setMaxAuditDepth(getMaxAuditDepth());
    nonPersistent.setMaxProducersToAudit(getMaxProducersToAudit());
  }
  nonPersistent.setMessageAudit(getMessageAudit());
  nonPersistent.start();
  persistent.setMessageAudit(getMessageAudit());
  persistent.start();
  pendingCount = persistent.size() + nonPersistent.size();
}

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

flowControlTimeoutTask.setName(getName()+" Producer Flow Control Timeout Task");
flowControlTimeoutTask.start();

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

flowControlTimeoutTask.setName(getName()+" Producer Flow Control Timeout Task");
flowControlTimeoutTask.start();

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

flowControlTimeoutTask.setName(getName()+" Producer Flow Control Timeout Task");
flowControlTimeoutTask.start();

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

flowControlTimeoutTask.setName(getName()+" Producer Flow Control Timeout Task");
flowControlTimeoutTask.start();

内容来源于网络，如有侵权，请联系作者删除！

queue

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Queue类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com