activemq-commits mailing list archives

Author: rajdavies
Date: Thu Jan 25 04:19:40 2007
New Revision: 499758

URL: http://svn.apache.org/viewvc?view=rev&rev=499758
Log:
increase average size overhead of a message to 500 bytes

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java?view=diff&rev=499758&r1=499757&r2=499758
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
Thu Jan 25 04:19:40 2007
@@ -41,7 +41,7 @@
  */
 abstract public class Message extends BaseCommand implements MarshallAware, MessageReference
{
 
-    public static final int AVERAGE_MESSAGE_SIZE_OVERHEAD = 300;
+    public static final int AVERAGE_MESSAGE_SIZE_OVERHEAD = 500;
     
     protected MessageId messageId;
     protected ActiveMQDestination originalDestination;
@@ -604,7 +604,7 @@
     }
 
     public int getSize() {
-        if( size == 0 ) {
+        if( size <=AVERAGE_MESSAGE_SIZE_OVERHEAD ) {
             size = AVERAGE_MESSAGE_SIZE_OVERHEAD;
             if( marshalledProperties!=null )
                 size += marshalledProperties.getLength();