[jboss-svn-commits] JBL Code SVN: r23659 - labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message.

[jboss-svn-commits at lists.jboss.org]

Author: tcunning
Date: 2008-10-31 13:36:26 -0400 (Fri, 31 Oct 2008)
New Revision: 23659

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
Log:
JBESB-2123
Make sure we only add bytes once per service.


Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java	2008-10-31 17:06:12 UTC (rev 23658)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java	2008-10-31 17:36:26 UTC (rev 23659)
@@ -432,7 +432,10 @@
 			time.value += asb.getProcTime();
 			LongHolder bProcessed = actionBytesProcessedHash.get(actionName + " " +  BYTES_PROCESSED);
 			bProcessed.value += asb.getBytesProcessed();
-			bytesProcessed += asb.getBytesProcessed();
+			
+			if (asb.getProcCount() == (actionNames.length-1)) {
+				bytesProcessed += asb.getBytesProcessed();				
+			}
 		} else if (ActionStatusBean.ACTION_FAILED.equals(asb.getStatus())) {
 			IntHolder count = actionFailedCounterHash.get(actionName + " " + FAILED_MESSAGE_COUNTER);
 			count.value++ ;
@@ -442,7 +445,10 @@
 			bFailed.value += asb.getBytesProcessed();
 			bytesFailed += asb.getBytesProcessed();
 		}
-		bytesOverall += asb.getBytesProcessed();
+		
+		if (asb.getProcCount() == 0) {
+			bytesOverall += asb.getBytesProcessed();
+		}	
 	}
 	
 	protected ObjectName getObjectName()