org.apache.activemq.command.Message.decrementReferenceCount()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.2k)|赞(0)|评价(0)|浏览(253)

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

Message.decrementReferenceCount介绍

暂无

代码示例

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

  1. @Override
  2. public void afterRollback() throws Exception {
  3. message.decrementReferenceCount();
  4. }
  5. });

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

  1. @Override
  2. public synchronized void drop() {
  3. dropped = true;
  4. lockOwner = null;
  5. message.decrementReferenceCount();
  6. }

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

  1. @Override
  2. public int decrementReferenceCount() {
  3. return message.decrementReferenceCount();
  4. }

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

  1. public void afterRollback() throws Exception {
  2. if (debug) {
  3. LOG.debug("Transacted message add rollback for: " + id + ", at: " + location);
  4. }
  5. synchronized (JournalMessageStore.this) {
  6. inFlightTxLocations.remove(location);
  7. }
  8. message.decrementReferenceCount();
  9. }
  10. });

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

  1. @Override
  2. protected void onCacheEviction(Map.Entry<MessageId, Message> eldest) {
  3. decMessageStoreStatistics(messageStoreStatistics, eldest.getValue());
  4. // We aren't tracking this anymore so remove our reference to it.
  5. eldest.getValue().decrementReferenceCount();
  6. }
  7. }

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

  1. @Override
  2. public void releaseLocks() {
  3. if (this.locked.compareAndSet(true, false)) {
  4. store.releaseLocalAsyncLock();
  5. globalQueueSemaphore.release();
  6. message.decrementReferenceCount();
  7. }
  8. }

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

  1. final void removeMessage(final MessageAck ack, final RecordLocation location) {
  2. synchronized (this) {
  3. lastLocation = location;
  4. MessageId id = ack.getLastMessageId();
  5. Message message = messages.remove(id);
  6. if (message == null) {
  7. messageAcks.add(ack);
  8. } else {
  9. message.decrementReferenceCount();
  10. }
  11. }
  12. }

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

  1. @Override
  2. public void releaseLocks() {
  3. if (this.locked.compareAndSet(true, false)) {
  4. message.decrementReferenceCount();
  5. store.releaseLocalAsyncLock();
  6. globalTopicSemaphore.release();
  7. }
  8. }

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

  1. void removeMessage(MessageId id) {
  2. Message removed;
  3. synchronized (this) {
  4. removed = map.remove(id);
  5. if ((lastBatch != null && lastBatch.equals(id)) || map.isEmpty()) {
  6. resetBatching();
  7. }
  8. }
  9. if (removed != null) {
  10. removed.decrementReferenceCount();
  11. }
  12. }

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

  1. public void removeMessage(MessageId msgId) throws IOException {
  2. synchronized (messageTable) {
  3. Message removed = messageTable.remove(msgId);
  4. if (removed != null) {
  5. removed.decrementReferenceCount();
  6. decMessageStoreStatistics(getMessageStoreStatistics(), removed);
  7. }
  8. if ((lastBatchId != null && lastBatchId.equals(msgId)) || messageTable.isEmpty()) {
  9. lastBatchId = null;
  10. }
  11. }
  12. }

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

  1. @Override
  2. public void afterCommit() throws Exception {
  3. if (store != null && messageContext.message.isPersistent()) {
  4. doPendingCursorAdditions();
  5. } else {
  6. cursorAdd(messageContext.message);
  7. messageSent(messageContext.context, messageContext.message);
  8. }
  9. messageContext.message.decrementReferenceCount();
  10. }

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

  1. @Override
  2. public void afterRollback() throws Exception {
  3. if (store != null && messageContext.message.isPersistent()) {
  4. rollbackPendingCursorAdditions(messageContext.message.getMessageId());
  5. }
  6. messageContext.message.decrementReferenceCount();
  7. }
  8. }

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

  1. @Override
  2. public void afterCommit() throws Exception {
  3. // It could take while before we receive the commit
  4. // operation.. by that time the message could have
  5. // expired..
  6. if (message.isExpired()) {
  7. if (broker.isExpired(message)) {
  8. getDestinationStatistics().getExpired().increment();
  9. broker.messageExpired(context, message, null);
  10. }
  11. message.decrementReferenceCount();
  12. return;
  13. }
  14. try {
  15. dispatch(context, message);
  16. } finally {
  17. message.decrementReferenceCount();
  18. }
  19. }

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

  1. message.decrementReferenceCount();

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

  1. dispatch(context, message);
  2. } finally {
  3. message.decrementReferenceCount();

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

  1. @Override
  2. protected void onCacheEviction(Map.Entry<MessageId, Message> eldest) {
  3. decMessageStoreStatistics(messageStoreStatistics, eldest.getValue());
  4. // We aren't tracking this anymore so remove our reference to it.
  5. eldest.getValue().decrementReferenceCount();
  6. }
  7. }

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

  1. @Override
  2. public void releaseLocks() {
  3. if (this.locked.compareAndSet(true, false)) {
  4. message.decrementReferenceCount();
  5. store.releaseLocalAsyncLock();
  6. globalTopicSemaphore.release();
  7. }
  8. }

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

  1. @Override
  2. public void releaseLocks() {
  3. if (this.locked.compareAndSet(true, false)) {
  4. store.releaseLocalAsyncLock();
  5. globalQueueSemaphore.release();
  6. message.decrementReferenceCount();
  7. }
  8. }

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

  1. void removeMessage(MessageId id) {
  2. Message removed;
  3. synchronized (this) {
  4. removed = map.remove(id);
  5. if ((lastBatch != null && lastBatch.equals(id)) || map.isEmpty()) {
  6. resetBatching();
  7. }
  8. }
  9. if (removed != null) {
  10. removed.decrementReferenceCount();
  11. }
  12. }

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

  1. public void removeMessage(MessageId msgId) throws IOException {
  2. synchronized (messageTable) {
  3. Message removed = messageTable.remove(msgId);
  4. if (removed != null) {
  5. removed.decrementReferenceCount();
  6. decMessageStoreStatistics(getMessageStoreStatistics(), removed);
  7. }
  8. if ((lastBatchId != null && lastBatchId.equals(msgId)) || messageTable.isEmpty()) {
  9. lastBatchId = null;
  10. }
  11. }
  12. }

相关文章

Message类方法