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

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

Author: tcunning
Date: 2009-10-13 11:43:17 -0400 (Tue, 13 Oct 2009)
New Revision: 29595

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
Log:
JBESB-2881
Add processing time to ServiceMessageCounter.


Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java	2009-10-13 14:58:24 UTC (rev 29594)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java	2009-10-13 15:43:17 UTC (rev 29595)
@@ -79,6 +79,7 @@
 	private long bytesFailed;
 	private long bytesProcessed;
 	private long bytesOverall;
+	private long timeProcessed;
 	
 	private Long alertTime = new Long("-1");
 	private Long alertLength = new Long("-1");
@@ -94,6 +95,7 @@
 	private static final String OVERALL_BYTES = "overall service count bytes";
 	private static final String OVERALL_BYTES_PROCESSED = "overall processedbytes";
 	private static final String OVERALL_BYTES_FAILED = "overall failed bytes";
+	private static final String OVERALL_TIME_PROCESSED = "overall service time processed";
 	
 	private static final String ALERT_TIME = "service alert time";
 	private static final String ALERT_LENGTH = "service alert length";
@@ -260,6 +262,7 @@
 		bytesProcessed = new Long(0);
 		bytesFailed = new Long(0);
 		bytesOverall = new Long(0);
+		timeProcessed = new Long (0);
 	}
 	
 	/**
@@ -271,6 +274,7 @@
 		bytesProcessed = 0 ;
 		bytesFailed = 0 ;
 		bytesOverall = 0;
+		timeProcessed = 0;
 		
 		for (String key : actionCounterHash.keySet()) {
 			actionCounterHash.put(key, new IntHolder());
@@ -304,7 +308,7 @@
 		int count = actionCounterHash.size() + actionProcessTimeHash.size()
 			+ actionFailedCounterHash.size() + actionBytesProcessedHash.size() 
 			+ actionBytesFailedHash.size() + actionLengthThresholdHash.size()
-			+ actionTimeThresholdHash.size() + 6; // the extra 6 here are overall service count, failed byte size
+			+ actionTimeThresholdHash.size() + 7; // the extra 6 here are overall service count, failed byte size
 												// processed byte size, overall bytes, alert time, and alert
 												// length
         MBeanAttributeInfo[] attrs = new MBeanAttributeInfo[count];
@@ -360,6 +364,11 @@
 		attrs[counter] = overallBytes;
 		counter++;		
 
+		MBeanAttributeInfo overallTimeProcessed = new MBeanAttributeInfo(OVERALL_TIME_PROCESSED, "java.lang.Long", 
+				"Property " + OVERALL_TIME_PROCESSED, true, false, false);
+		attrs[counter] = overallTimeProcessed;
+		counter++;		
+		
 		try {
 			Method alertTimeGetter = this.getClass().getMethod("getAlertTime", new Class[0]);
 			Method alertTimeSetter = this.getClass().getMethod("setAlertTime", new Class[]{Long.class});
@@ -484,6 +493,8 @@
     		return bytesFailed;
     	} else if (OVERALL_BYTES.equals(key)) {
     		return bytesOverall;
+    	} else if (OVERALL_TIME_PROCESSED.equals(key)) {
+    		return timeProcessed;
     	} else if (ALERT_TIME.equals(key)) {
     		return alertTime;
     	} else if (ALERT_LENGTH.equals(key)) {
@@ -697,6 +708,7 @@
 			count.value++ ;
 			LongHolder time = actionProcessTimeHash.get(actionName + " " + PROCESSING_TIME);
 			time.value += asb.getProcTime();
+			timeProcessed += asb.getProcTime();
 			LongHolder bProcessed = actionBytesProcessedHash.get(actionName + " " +  BYTES_PROCESSED);
 			bProcessed.value += asb.getBytesProcessed();			
 			
@@ -710,6 +722,7 @@
 			count.value++ ;
 			LongHolder time = actionProcessTimeHash.get(actionName + " " + PROCESSING_TIME);
 			time.value += asb.getProcTime();
+			timeProcessed += asb.getProcTime();
 			LongHolder bFailed = actionBytesFailedHash.get(actionName + " " +  BYTES_FAILED);
 			bFailed.value += asb.getBytesProcessed();
 			bytesFailed += asb.getBytesProcessed();
@@ -744,4 +757,5 @@
 			return Long.toString(value);
 		}
 	}
+
 }