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

Queue.messageExpired介绍

暂无

代码示例

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

public void messageExpired(ConnectionContext context, MessageReference reference) {
  messageExpired(context, null, reference);
}

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

public void processExpired() {
  for (Message message: toExpire) {
    messageExpired(createConnectionContext(), createMessageReference(message));
    // drop message will decrement so counter
    // balance here
    destinationStatistics.getMessages().increment();
  }
  toExpire.clear();
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

if (processExpired && ref.isExpired()) {
  if (broker.isExpired(ref)) {
    messageExpired(createConnectionContext(), ref);
  } else {
    ref.decrementReferenceCount();

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

public void messageExpired(ConnectionContext context, MessageReference reference) {
  messageExpired(context, null, reference);
}

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

public void messageExpired(ConnectionContext context, MessageReference reference) {
  messageExpired(context, null, reference);
}

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

public void messageExpired(ConnectionContext context, MessageReference reference) {
  messageExpired(context, null, reference);
}

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

public void messageExpired(ConnectionContext context, MessageReference reference) {
  messageExpired(context, null, reference);
}

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

public void processExpired() {
  for (Message message: toExpire) {
    messageExpired(createConnectionContext(), createMessageReference(message));
    // drop message will decrement so counter
    // balance here
    destinationStatistics.getMessages().increment();
  }
  toExpire.clear();
}

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

public void processExpired() {
  for (Message message: toExpire) {
    messageExpired(createConnectionContext(), createMessageReference(message));
    // drop message will decrement so counter
    // balance here
    destinationStatistics.getMessages().increment();
  }
  toExpire.clear();
}

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

public void processExpired() {
  for (Message message: toExpire) {
    messageExpired(createConnectionContext(), createMessageReference(message));
    // drop message will decrement so counter
    // balance here
    destinationStatistics.getMessages().increment();
  }
  toExpire.clear();
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

if (broker.isExpired(ref)) {
    LOG.debug("expiring from pagedInPending: " + ref);
    messageExpired(connectionContext, ref);
if (broker.isExpired(ref)) {
  LOG.debug("expiring from pagedInMessages: " + ref);
  messageExpired(connectionContext, ref);
} else {
  pagedInMessagesLock.writeLock().lock();
        if (broker.isExpired(node)) {
          LOG.debug("expiring from messages: " + node);
          messageExpired(connectionContext, createMessageReference(node.getMessage()));

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

messageExpired(createConnectionContext(), createMessageReference(message));

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

if (ref.isExpired()) {
  if (broker.isExpired(ref)) {
    messageExpired(createConnectionContext(), ref);
  } else {
    ref.decrementReferenceCount();

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

if (processExpired && ref.isExpired()) {
  if (broker.isExpired(ref)) {
    messageExpired(createConnectionContext(), ref);
  } else {
    ref.decrementReferenceCount();

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

if (processExpired && ref.isExpired()) {
  if (broker.isExpired(ref)) {
    messageExpired(createConnectionContext(), ref);
  } else {
    ref.decrementReferenceCount();

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

if (processExpired && ref.isExpired()) {
  if (broker.isExpired(ref)) {
    messageExpired(createConnectionContext(), ref);
  } else {
    ref.decrementReferenceCount();