You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/01/25 13:19:41 UTC
svn commit: r499758 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
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();