本文整理了Java中org.apache.activemq.command.Message.incrementReferenceCount()
方法的一些代码示例,展示了Message.incrementReferenceCount()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.incrementReferenceCount()
方法的具体详情如下:
包路径:org.apache.activemq.command.Message
类名称: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));
}
}
}
内容来源于网络,如有侵权,请联系作者删除!