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

Message.incrementReferenceCount介绍

暂无

代码示例

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

@Override
public int incrementReferenceCount() {
  return message.incrementReferenceCount();
}

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

CursorAddSync(MessageContext messageContext) {
  this.messageContext = messageContext;
  this.messageContext.message.incrementReferenceCount();
}

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

void addMessage(MessageId id, Message message) {
  synchronized (this) {
    map.put(id, message);
  }
  message.incrementReferenceCount();
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalTopicSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalQueueSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public synchronized LinkedList<MessageReference> pageInList(int maxItems) {
  LinkedList<MessageReference> result = new LinkedList<MessageReference>();
  int count = 0;
  for (Iterator<MessageReference> i = memoryList.iterator(); i.hasNext() && count < maxItems;) {
    MessageReference ref = i.next();
    ref.incrementReferenceCount();
    result.add(ref);
    count++;
  }
  if (count < maxItems && !isDiskListEmpty()) {
    for (Iterator<MessageReference> i = new DiskIterator(); i.hasNext() && count < maxItems;) {
      Message message = (Message) i.next();
      message.setRegionDestination(regionDestination);
      message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());
      message.incrementReferenceCount();
      result.add(message);
      count++;
    }
  }
  return result;
}

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

@Override
public synchronized void addMessage(ConnectionContext context, Message message) throws IOException {
  synchronized (messageTable) {
    messageTable.put(message.getMessageId(), message);
    incMessageStoreStatistics(getMessageStoreStatistics(), message);
    message.incrementReferenceCount();
    message.getMessageId().setFutureOrSequenceLong(sequenceId++);
    if (indexListener != null) {
      indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
    }
  }
}

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

message.incrementReferenceCount();

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

message.incrementReferenceCount();
batchList.addMessageLast(message);
clearIterator(true);

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

message.incrementReferenceCount();

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

void addMessage(MessageId id, Message message) {
  synchronized (this) {
    map.put(id, message);
  }
  message.incrementReferenceCount();
}

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

void addMessage(MessageId id, Message message) {
  synchronized (this) {
    map.put(id, message);
  }
  message.incrementReferenceCount();
}

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

void addMessage(MessageId id, Message message) {
  synchronized (this) {
    map.put(id, message);
  }
  message.incrementReferenceCount();
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalQueueSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalQueueSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalQueueSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public void aquireLocks() {
  if (this.locked.compareAndSet(false, true)) {
    try {
      globalTopicSemaphore.acquire();
      store.acquireLocalAsyncLock();
      message.incrementReferenceCount();
    } catch (InterruptedException e) {
      LOG.warn("Failed to aquire lock", e);
    }
  }
}

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

@Override
public synchronized void addMessage(ConnectionContext context, Message message) throws IOException {
  synchronized (messageTable) {
    messageTable.put(message.getMessageId(), message);
    incMessageStoreStatistics(getMessageStoreStatistics(), message);
    message.incrementReferenceCount();
    message.getMessageId().setFutureOrSequenceLong(sequenceId++);
    if (indexListener != null) {
      indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
    }
  }
}

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

@Override
public synchronized void addMessage(ConnectionContext context, Message message) throws IOException {
  synchronized (messageTable) {
    messageTable.put(message.getMessageId(), message);
    incMessageStoreStatistics(getMessageStoreStatistics(), message);
    message.incrementReferenceCount();
    message.getMessageId().setFutureOrSequenceLong(sequenceId++);
    if (indexListener != null) {
      indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
    }
  }
}

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

@Override
public synchronized void addMessage(ConnectionContext context, Message message) throws IOException {
  synchronized (messageTable) {
    messageTable.put(message.getMessageId(), message);
    incMessageStoreStatistics(getMessageStoreStatistics(), message);
    message.incrementReferenceCount();
    message.getMessageId().setFutureOrSequenceLong(sequenceId++);
    if (indexListener != null) {
      indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
    }
  }
}