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

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

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

Message.getMemoryUsage介绍

暂无

代码示例

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

  1. @Override
  2. public int incrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = ++referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 1 && getMemoryUsage() != null) {
  10.     getMemoryUsage().increaseUsage(size);
  11.     //System.err.println("INCREASE USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  12.   }
  13.   //System.out.println(" + "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  14.   return rc;
  15. }

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

  1. @Override
  2. public int decrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = --referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 0 && getMemoryUsage() != null) {
  10.     getMemoryUsage().decreaseUsage(size);
  11.     //Thread.dumpStack();
  12.     //System.err.println("DECREADED USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  13.   }
  14.   //System.out.println(" - "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  15.   return rc;
  16. }

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

  1. public PendingMarshalUsageTracker(final Message message) {
  2.   usage = message.getMemoryUsage();
  3.   if (usage != null) {
  4.     messageSize = message.getSize();
  5.     usage.increaseUsage(messageSize);
  6.   }
  7. }

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

  1. if (recordUniqueId(message.getMessageId())) {
  2.   if (!cached) {
  3.     if( message.getMemoryUsage()==null ) {
  4.       message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());

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

  1. public int incrementReferenceCount() {
  2.   int rc;
  3.   int size;
  4.   synchronized (this) {
  5.     rc = ++referenceCount;
  6.     size = getSize();
  7.   }
  8.   if (rc == 1 && getMemoryUsage() != null) {
  9.     getMemoryUsage().increaseUsage(size);
  10.     //System.err.println("INCREASE USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  11.   }
  12.   //System.out.println(" + "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  13.   return rc;
  14. }

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

  1. @Override
  2. public int incrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = ++referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 1 && getMemoryUsage() != null) {
  10.     getMemoryUsage().increaseUsage(size);
  11.     //System.err.println("INCREASE USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  12.   }
  13.   //System.out.println(" + "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  14.   return rc;
  15. }

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

  1. @Override
  2. public int incrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = ++referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 1 && getMemoryUsage() != null) {
  10.     getMemoryUsage().increaseUsage(size);
  11.     //System.err.println("INCREASE USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  12.   }
  13.   //System.out.println(" + "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  14.   return rc;
  15. }

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

  1. @Override
  2. public int decrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = --referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 0 && getMemoryUsage() != null) {
  10.     getMemoryUsage().decreaseUsage(size);
  11.     //Thread.dumpStack();
  12.     //System.err.println("DECREADED USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  13.   }
  14.   //System.out.println(" - "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  15.   return rc;
  16. }

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

  1. @Override
  2. public int decrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = --referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 0 && getMemoryUsage() != null) {
  10.     getMemoryUsage().decreaseUsage(size);
  11.     //Thread.dumpStack();
  12.     //System.err.println("DECREADED USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  13.   }
  14.   //System.out.println(" - "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  15.   return rc;
  16. }

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

  1. @Override
  2. public int decrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = --referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 0 && getMemoryUsage() != null) {
  10.     getMemoryUsage().decreaseUsage(size);
  11.     //Thread.dumpStack();
  12.     //System.err.println("DECREADED USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  13.   }
  14.   //System.out.println(" - "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  15.   return rc;
  16. }

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

  1. @Override
  2. public int incrementReferenceCount() {
  3.   int rc;
  4.   int size;
  5.   synchronized (this) {
  6.     rc = ++referenceCount;
  7.     size = getSize();
  8.   }
  9.   if (rc == 1 && getMemoryUsage() != null) {
  10.     getMemoryUsage().increaseUsage(size);
  11.     //System.err.println("INCREASE USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  12.   }
  13.   //System.out.println(" + "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  14.   return rc;
  15. }

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

  1. public int decrementReferenceCount() {
  2.   int rc;
  3.   int size;
  4.   synchronized (this) {
  5.     rc = --referenceCount;
  6.     size = getSize();
  7.   }
  8.   if (rc == 0 && getMemoryUsage() != null) {
  9.     getMemoryUsage().decreaseUsage(size);
  10.     //Thread.dumpStack();
  11.     //System.err.println("DECREADED USAGE " + System.identityHashCode(getMemoryUsage()) + " PERCENT = " + getMemoryUsage().getPercentUsage());
  12.   }
  13.   //System.out.println(" - "+getMemoryUsage().getName()+" :::: "+getMessageId()+"rc="+rc);
  14.   return rc;
  15. }

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

  1. public PendingMarshalUsageTracker(final Message message) {
  2.   usage = message.getMemoryUsage();
  3.   if (usage != null) {
  4.     messageSize = message.getSize();
  5.     usage.increaseUsage(messageSize);
  6.   }
  7. }

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

  1. public PendingMarshalUsageTracker(final Message message) {
  2.   usage = message.getMemoryUsage();
  3.   if (usage != null) {
  4.     messageSize = message.getSize();
  5.     usage.increaseUsage(messageSize);
  6.   }
  7. }

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

  1. public PendingMarshalUsageTracker(final Message message) {
  2.   usage = message.getMemoryUsage();
  3.   if (usage != null) {
  4.     messageSize = message.getSize();
  5.     usage.increaseUsage(messageSize);
  6.   }
  7. }

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

  1. public synchronized boolean recoverMessage(Message message, boolean cached) throws Exception {
  2.   boolean recovered = false;
  3.   if (recordUniqueId(message.getMessageId())) {
  4.     if (!cached) {
  5.       message.setRegionDestination(regionDestination);
  6.       if( message.getMemoryUsage()==null ) {
  7.         message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());
  8.       }
  9.     }
  10.     message.incrementReferenceCount();
  11.     batchList.addMessageLast(message);
  12.     clearIterator(true);
  13.     recovered = true;
  14.     storeHasMessages = true;
  15.   } else {
  16.     /*
  17.      * we should expect to get these - as the message is recorded as it before it goes into
  18.      * the cache. If subsequently, we pull out that message from the store (before its deleted)
  19.      * it will be a duplicate - but should be ignored
  20.      */
  21.     if (LOG.isTraceEnabled()) {
  22.       LOG.trace(this + " - cursor got duplicate: " + message.getMessageId() + ", " + message.getPriority());
  23.     }
  24.   }
  25.   return recovered;
  26. }

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

  1. if (recordUniqueId(message.getMessageId())) {
  2.   if (!cached) {
  3.     if( message.getMemoryUsage()==null ) {
  4.       message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());

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

  1. if (recordUniqueId(message.getMessageId())) {
  2.   if (!cached) {
  3.     if( message.getMemoryUsage()==null ) {
  4.       message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());

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

  1. if (recordUniqueId(message.getMessageId())) {
  2.   if (!cached) {
  3.     if( message.getMemoryUsage()==null ) {
  4.       message.setMemoryUsage(this.getSystemUsage().getMemoryUsage());

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Message类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com