[jboss-svn-commits] JBL Code SVN: r23381 - 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-08 22:50:44 -0400 (Wed, 08 Oct 2008)
New Revision: 23381

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
Log:
bug:JBESB-2043
Make sure we add the failed bytes to the hash and that we update the 
counter on action failure.


Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java	2008-10-09 01:47:13 UTC (rev 23380)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java	2008-10-09 02:50:44 UTC (rev 23381)
@@ -554,6 +554,10 @@
 						MessageCounterStatistics.getMessageCounterStatistics().update(new MessageStatusBean(totalProcTime, message,
 							MessageStatusBean.MESSAGE_FAILED));
 
+						final long processTime = System.nanoTime() - actionStart;
+						serviceMessageCounter.update(new ActionStatusBean(processTime, count, message,
+							ActionStatusBean.ACTION_FAILED));
+							
 						if (throwRuntime)
 						{
 							throw (RuntimeException)ex ;

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-09 01:47:13 UTC (rev 23380)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java	2008-10-09 02:50:44 UTC (rev 23381)
@@ -433,15 +433,15 @@
 			Integer bProcessed = actionBytesProcessedHash.get(actionName + " " +  BYTES_PROCESSED);
 			bProcessed = bProcessed.intValue() + asb.getBytesProcessed();
 			actionBytesProcessedHash.put(actionName + " " + BYTES_PROCESSED, bProcessed);
-			bytesProcessed += asb.getBytesProcessed();
+			bytesProcessed += new Integer(bytesProcessed.intValue() + asb.getBytesProcessed());
 		} else if (ActionStatusBean.ACTION_FAILED.equals(asb.getStatus())) {
 			Integer count = actionFailedCounterHash.get(actionName + " " + FAILED_MESSAGE_COUNTER);
 			count = count.intValue() + 1;
 			actionFailedCounterHash.put(actionName + " " + FAILED_MESSAGE_COUNTER, count);
-			bytesFailed += asb.getBytesProcessed();
 			Integer bFailed = actionBytesFailedHash.get(actionName + " " +  BYTES_FAILED);
 			bFailed = bFailed.intValue() + asb.getBytesProcessed();
-			actionBytesProcessedHash.put(actionName + " " + BYTES_FAILED, bFailed);
+			bytesFailed += new Integer(bytesFailed.intValue() + asb.getBytesProcessed());
+			actionBytesFailedHash.put(actionName + " " + BYTES_FAILED, bFailed);
 		}		
 	}