[jboss-svn-commits] JBL Code SVN: r24809 - labs/jbossesb/trunk/product/tools/jonplugin/src/main/java/org/jbosson/plugins/jbossesb.

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

Author: tcunning
Date: 2009-01-19 21:56:47 -0500 (Mon, 19 Jan 2009)
New Revision: 24809

Modified:
   labs/jbossesb/trunk/product/tools/jonplugin/src/main/java/org/jbosson/plugins/jbossesb/ActionComponent.java
Log:
JBESB-2294
Make sure bytes are long.


Modified: labs/jbossesb/trunk/product/tools/jonplugin/src/main/java/org/jbosson/plugins/jbossesb/ActionComponent.java
===================================================================
--- labs/jbossesb/trunk/product/tools/jonplugin/src/main/java/org/jbosson/plugins/jbossesb/ActionComponent.java	2009-01-20 02:53:30 UTC (rev 24808)
+++ labs/jbossesb/trunk/product/tools/jonplugin/src/main/java/org/jbosson/plugins/jbossesb/ActionComponent.java	2009-01-20 02:56:47 UTC (rev 24809)
@@ -45,7 +45,7 @@
     private static final String PROCESSING_TIME = "processing time";
     private static final String OVERALL_BYTES_PROCESSED = "processed bytes";
     private static final String OVERALL_BYTES_FAILED = "failed bytes";
-
+    
     private static final String OVERALL_METRIC_NAME = "overallMessagesCount";
     private static final String SUCCESS_METRIC_NAME = "successProcessedCount";
     private static final String FAILED_METRIC_NAME = "failedProcessedCount";
@@ -110,8 +110,8 @@
     	int success = 0;
     	int failed = 0;
     	
-    	int counterBytesFailed = 0;
-    	int counterBytesProcessed = 0;
+    	long counterBytesFailed = 0;
+    	long counterBytesProcessed = 0;
     	for (MeasurementScheduleRequest request : requests) {
         	String metricName = request.getName();
         	if (metricName.equals (SUCCESS_METRIC_NAME)) {
@@ -143,17 +143,17 @@
         		}
         	} else if (metricName.equals(BYTESPROCESSED_METRIC_NAME)) {
         		EmsAttribute attribute = this.bean.getAttribute(actionName + " " + OVERALL_BYTES_PROCESSED);
-        		Integer bytesProcessed = new Integer(0);
+        		Long bytesProcessed = new Long(0);
         		if (attribute != null) {
-        			bytesProcessed = (Integer) attribute.refresh();
+        			bytesProcessed = (Long) attribute.refresh();
         			counterBytesProcessed = bytesProcessed.intValue();
         		}
         		report.addData(new MeasurementDataNumeric(request, new Double(bytesProcessed.doubleValue())));
         	} else if (metricName.equals(BYTESFAILED_METRIC_NAME)) {
         		EmsAttribute attribute = this.bean.getAttribute(actionName + " " + OVERALL_BYTES_FAILED);
-        		Integer bytesFailed = new Integer(0);
+        		Long bytesFailed = new Long(0);
         		if (attribute != null) {
-        			bytesFailed = (Integer) attribute.refresh();
+        			bytesFailed = (Long) attribute.refresh();
         			counterBytesFailed += bytesFailed.intValue();
         		}
         		report.addData(new MeasurementDataNumeric(request, new Double(bytesFailed.doubleValue())));