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

Queue.onMessageWithNoConsumers介绍

暂无

代码示例

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

final void messageSent(final ConnectionContext context, final Message msg) throws Exception {
  pendingSends.decrementAndGet();
  destinationStatistics.getEnqueues().increment();
  destinationStatistics.getMessages().increment();
  destinationStatistics.getMessageSize().addSize(msg.getSize());
  messageDelivered(context, msg);
  consumersLock.readLock().lock();
  try {
    if (consumers.isEmpty()) {
      onMessageWithNoConsumers(context, msg);
    }
  }finally {
    consumersLock.readLock().unlock();
  }
  LOG.debug("{} Message {} sent to {}", new Object[]{ broker.getBrokerName(), msg.getMessageId(), this.destination });
  wakeup();
}

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

final void messageSent(final ConnectionContext context, final Message msg) throws Exception {     
  destinationStatistics.getEnqueues().increment();
  destinationStatistics.getMessages().increment();
  messageDelivered(context, msg);
  consumersLock.readLock().lock();
  try {
    if (consumers.isEmpty()) {
      onMessageWithNoConsumers(context, msg);
    }
  }finally {
    consumersLock.readLock().unlock();
  }
  if (LOG.isTraceEnabled()) {
    LOG.trace("Message " + msg.getMessageId() + " sent to " + this.destination);
  }
  wakeup();
}

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

final void messageSent(final ConnectionContext context, final Message msg) throws Exception {
  pendingSends.decrementAndGet();
  destinationStatistics.getEnqueues().increment();
  destinationStatistics.getMessages().increment();
  destinationStatistics.getMessageSize().addSize(msg.getSize());
  messageDelivered(context, msg);
  consumersLock.readLock().lock();
  try {
    if (consumers.isEmpty()) {
      onMessageWithNoConsumers(context, msg);
    }
  }finally {
    consumersLock.readLock().unlock();
  }
  LOG.debug("{} Message {} sent to {}", new Object[]{ broker.getBrokerName(), msg.getMessageId(), this.destination });
  wakeup();
}

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

final void messageSent(final ConnectionContext context, final Message msg) throws Exception {
  pendingSends.decrementAndGet();
  destinationStatistics.getEnqueues().increment();
  destinationStatistics.getMessages().increment();
  destinationStatistics.getMessageSize().addSize(msg.getSize());
  messageDelivered(context, msg);
  consumersLock.readLock().lock();
  try {
    if (consumers.isEmpty()) {
      onMessageWithNoConsumers(context, msg);
    }
  }finally {
    consumersLock.readLock().unlock();
  }
  LOG.debug("{} Message {} sent to {}", new Object[]{ broker.getBrokerName(), msg.getMessageId(), this.destination });
  wakeup();
}

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

final void messageSent(final ConnectionContext context, final Message msg) throws Exception {
  pendingSends.decrementAndGet();
  destinationStatistics.getEnqueues().increment();
  destinationStatistics.getMessages().increment();
  destinationStatistics.getMessageSize().addSize(msg.getSize());
  messageDelivered(context, msg);
  consumersLock.readLock().lock();
  try {
    if (consumers.isEmpty()) {
      onMessageWithNoConsumers(context, msg);
    }
  }finally {
    consumersLock.readLock().unlock();
  }
  LOG.debug("{} Message {} sent to {}", new Object[]{ broker.getBrokerName(), msg.getMessageId(), this.destination });
  wakeup();
}