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

Broker.getScheduler介绍

暂无

代码示例

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

@Override
public void setBrokerService(Broker broker) {
  this.scheduler = broker.getScheduler();
  this.broker = broker;
}

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

public void setBroker(Broker broker) {  
  this.scheduler = broker.getScheduler();
}

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

@Override
public Scheduler getScheduler() {
  return getNext().getScheduler();
}

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

public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws JMSException {
  super(broker,context, info);
  this.usageManager=usageManager;
  pending = cursor;
  try {
    pending.start();
  } catch (Exception e) {
    throw new JMSException(e.getMessage());
  }
  this.scheduler = broker.getScheduler();
}

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

public TopicSubscription(Broker broker,ConnectionContext context, ConsumerInfo info, SystemUsage usageManager) throws Exception {
  super(broker, context, info);
  this.usageManager = usageManager;
  String matchedName = "TopicSubscription:" + CURSOR_NAME_COUNTER.getAndIncrement() + "[" + info.getConsumerId().toString() + "]";
  if (info.getDestination().isTemporary() || broker.getTempDataStore()==null ) {
    this.matched = new VMPendingMessageCursor(false);
  } else {
    this.matched = new FilePendingMessageCursor(broker,matchedName,false);
  }
  this.scheduler = broker.getScheduler();
}

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

/**
 * @param brokerService
 * @param store
 * @param destination
 * @param parentStats
 * @throws Exception
 */
public BaseDestination(BrokerService brokerService, MessageStore store, ActiveMQDestination destination, DestinationStatistics parentStats) throws Exception {
  this.brokerService = brokerService;
  this.broker = brokerService.getBroker();
  this.store = store;
  this.destination = destination;
  // let's copy the enabled property from the parent DestinationStatistics
  this.destinationStatistics.setEnabled(parentStats.isEnabled());
  this.destinationStatistics.setParent(parentStats);
  this.systemUsage = new SystemUsage(brokerService.getProducerSystemUsage(), destination.toString());
  this.memoryUsage = this.systemUsage.getMemoryUsage();
  this.memoryUsage.setUsagePortion(1.0f);
  this.regionBroker = brokerService.getRegionBroker();
  this.scheduler = brokerService.getBroker().getScheduler();
}

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

@Override
public void setBrokerService(Broker broker) {
  this.scheduler = broker.getScheduler();
  this.broker = broker;
}

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

public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws InvalidSelectorException {
  super(broker,context, info);
  this.usageManager=usageManager;
  pending = cursor;
  this.scheduler = broker.getScheduler();
}

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

@Override
public void setBrokerService(Broker broker) {
  this.scheduler = broker.getScheduler();
  this.broker = broker;
}

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

public void setBrokerService(Broker broker) {
  this.scheduler = broker.getScheduler();
  this.broker = broker;
}

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

@Override
public void setBrokerService(Broker broker) {
  this.scheduler = broker.getScheduler();
  this.broker = broker;
}

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

@Override
public Scheduler getScheduler() {
  return getNext().getScheduler();
}

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

@Override
public Scheduler getScheduler() {
  return getNext().getScheduler();
}

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

@Override
public Scheduler getScheduler() {
  return getNext().getScheduler();
}

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

public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws JMSException {
  super(broker,context, info);
  this.usageManager=usageManager;
  pending = cursor;
  try {
    pending.start();
  } catch (Exception e) {
    throw new JMSException(e.getMessage());
  }
  this.scheduler = broker.getScheduler();
}

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

public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws JMSException {
  super(broker,context, info);
  this.usageManager=usageManager;
  pending = cursor;
  try {
    pending.start();
  } catch (Exception e) {
    throw new JMSException(e.getMessage());
  }
  this.scheduler = broker.getScheduler();
}

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

public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws JMSException {
  super(broker,context, info);
  this.usageManager=usageManager;
  pending = cursor;
  try {
    pending.start();
  } catch (Exception e) {
    throw new JMSException(e.getMessage());
  }
  this.scheduler = broker.getScheduler();
}

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

public TopicSubscription(Broker broker,ConnectionContext context, ConsumerInfo info, SystemUsage usageManager) throws Exception {
  super(broker, context, info);
  this.usageManager = usageManager;
  String matchedName = "TopicSubscription:" + CURSOR_NAME_COUNTER.getAndIncrement() + "[" + info.getConsumerId().toString() + "]";
  if (info.getDestination().isTemporary() || broker.getTempDataStore()==null ) {
    this.matched = new VMPendingMessageCursor(false);
  } else {
    this.matched = new FilePendingMessageCursor(broker,matchedName,false);
  }
  this.scheduler = broker.getScheduler();
}

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

public TopicSubscription(Broker broker,ConnectionContext context, ConsumerInfo info, SystemUsage usageManager) throws Exception {
  super(broker, context, info);
  this.usageManager = usageManager;
  String matchedName = "TopicSubscription:" + CURSOR_NAME_COUNTER.getAndIncrement() + "[" + info.getConsumerId().toString() + "]";
  if (info.getDestination().isTemporary() || broker.getTempDataStore()==null ) {
    this.matched = new VMPendingMessageCursor(false);
  } else {
    this.matched = new FilePendingMessageCursor(broker,matchedName,false);
  }
  this.scheduler = broker.getScheduler();
}

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

public TopicSubscription(Broker broker,ConnectionContext context, ConsumerInfo info, SystemUsage usageManager) throws Exception {
  super(broker, context, info);
  this.usageManager = usageManager;
  String matchedName = "TopicSubscription:" + CURSOR_NAME_COUNTER.getAndIncrement() + "[" + info.getConsumerId().toString() + "]";
  if (info.getDestination().isTemporary() || broker.getTempDataStore()==null ) {
    this.matched = new VMPendingMessageCursor(false);
  } else {
    this.matched = new FilePendingMessageCursor(broker,matchedName,false);
  }
  this.scheduler = broker.getScheduler();
}