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

Queue.wakeup介绍

暂无

代码示例

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

@Override
public void afterCommit() throws Exception {
  dropMessage(reference);
  wakeup();
}

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

@Override
  public void afterRollback() throws Exception {
    reference.setAcked(false);
    wakeup();
  }
});

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

public void resumeDispatch() {
  dispatchSelector.resume();
  wakeup();
}

代码示例来源：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: apache/activemq

browserDispatches.remove(browserDispatch);
} else {
  wakeup();

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

wakeup();
wakeup();

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

wakeup();
wakeup();

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

@Override
public void afterCommit() throws Exception {
  dropMessage(reference);
  wakeup();
}

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

@Override
public void afterCommit() throws Exception {
  dropMessage(reference);
  wakeup();
}

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

@Override
public void afterCommit() throws Exception {
  dropMessage(reference);
  wakeup();
}

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

@Override
  public void afterRollback() throws Exception {
    reference.setAcked(false);
    wakeup();
  }
});

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

@Override
  public void afterRollback() throws Exception {
    reference.setAcked(false);
    wakeup();
  }
});

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

public void resumeDispatch() {
  dispatchSelector.resume();
  wakeup();
}

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

@Override
  public void afterRollback() throws Exception {
    reference.setAcked(false);
    wakeup();
  }
});

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

public void resumeDispatch() {
  dispatchSelector.resume();
  wakeup();
}

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

public void resumeDispatch() {
  dispatchSelector.resume();
  wakeup();
}

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

@Override
public void afterCommit() throws Exception {
  getDestinationStatistics().getDequeues().increment();
  dropMessage(reference);
  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-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();
}

代码示例来源：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();
}