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

Queue.started介绍

暂无

代码示例

代码示例来源：origin: advantageous/qbit

/**
 * started
 *
 * @return started
 */
@Override
public boolean started() {
  return queue.started();
}

代码示例来源：origin: advantageous/qbit

private void checkStarted() {
  if (checkQueueSize) {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: advantageous/qbit

private void checkStarted() {
  if (checkQueueSize) {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: io.advantageous.qbit/qbit-core

/**
 * started
 *
 * @return started
 */
@Override
public boolean started() {
  return queue.started();
}

代码示例来源：origin: com.github.advantageous/qbit-core

/**
 * started
 * @return started
 */
@Override
public boolean started() {
  return queue.started();
}

代码示例来源：origin: advantageous/qbit

@Test
public void testSendConsume() throws Exception {
  final Map<String, Person> noPerson = personReceiveQueue.poll();
  assertNull(noPerson);
  personSendQueue.send(Maps.map("Geoff", new Person("Geoff")));
  personSendQueue.send(Maps.map("Rick", new Person("Rick")));
  personSendQueue.flushSends();
  final Map<String, Person> geoff = personReceiveQueue.pollWait();
  final Map<String, Person> rick = personReceiveQueue.pollWait();
  assertEquals("Geoff", geoff.get("Geoff").name);
  assertEquals("Rick", rick.get("Rick").name);
  assertEquals(false, personQueue.started());
}

代码示例来源：origin: advantageous/qbit

@Test
public void testSendConsume() throws Exception {
  final List<Person> noPerson = personReceiveQueue.poll();
  assertNull(noPerson);
  personSendQueue.send(Lists.list(new Person("Geoff")));
  personSendQueue.send(Lists.list(new Person("Rick")));
  personSendQueue.flushSends();
  final List<Person> geoff = personReceiveQueue.pollWait();
  final List<Person> rick = personReceiveQueue.pollWait();
  assertEquals("Geoff", geoff.get(0).name);
  assertEquals("Rick", rick.get(0).name);
  assertEquals(false, personQueue.started());
}

代码示例来源：origin: io.advantageous.qbit/qbit-core

private void checkStarted() {
  if (checkQueueSize) {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: io.advantageous.qbit/qbit-core

private void checkStarted() {
  if (checkQueueSize) {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: com.github.advantageous/qbit-core

private void checkStarted() {
  if (checkQueueSize)  {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: com.github.advantageous/qbit-core

private void checkStarted() {
  if (checkQueueSize)  {
    if (queue.size() > checkQueueSizeWarnIfOver) {
      logger.warn("{} :: name {} queue is filling up", this.getClass().getSimpleName(), name);
    }
  }
  if (checkStart) {
    if (checkEveryStarted % checkStartWarnEvery == 0) {
      if (!owner.started()) {
        logger.warn("{} :: name {} send queue NOT STARTED", this.getClass().getSimpleName(), name);
      }
    }
    checkEveryStarted++;
  }
}

代码示例来源：origin: advantageous/qbit

@Test
public void testSendConsume() throws Exception {
  final Person noPerson = personReceiveQueue.poll();
  assertNull(noPerson);
  personSendQueue.send(new Person("Geoff"));
  personSendQueue.send(new Person("Rick"));
  personSendQueue.flushSends();
  final Person geoff = personReceiveQueue.pollWait();
  final Person rick = personReceiveQueue.pollWait();
  assertEquals("Geoff", geoff.name);
  assertEquals("Rick", rick.name);
  assertEquals(false, personQueue.started());
}