[jboss-svn-commits] JBL Code SVN: r24807 - labs/jbossesb/trunk/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server.

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

Author: tcunning
Date: 2009-01-19 21:52:48 -0500 (Mon, 19 Jan 2009)
New Revision: 24807

Modified:
   labs/jbossesb/trunk/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFiler.java
Log:
JBESB-2294
Make sure the total number of bytes we collect is a Long.


Modified: labs/jbossesb/trunk/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFiler.java
===================================================================
--- labs/jbossesb/trunk/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFiler.java	2009-01-20 02:51:14 UTC (rev 24806)
+++ labs/jbossesb/trunk/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFiler.java	2009-01-20 02:52:48 UTC (rev 24807)
@@ -102,13 +102,16 @@
 					data = (Integer) f_sb.getData();
 				} catch (Exception e) {
 				}
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, data, null);
 			} else if (f_sb.getType().equals("long")) {
 				Long data = (Long) f_sb.getData();
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, new Integer(data.intValue()), null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null, null);
+			} else if (f_sb.getType().equals("java.lang.Long")) {
+				Long data = (Long) f_sb.getData();
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null, null);
 			} else if (f_sb.getType().equals("int")) {
 				Integer data = (Integer) f_sb.getData();
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, data, null);
 			} else {
 				logger.error ("ERROR - found type of " + f_sb.getType() + " for " + f_sb.getAttribute());
 				return;
@@ -117,18 +120,18 @@
 			if (f_sb.getType().equals("java.lang.Double")) {
 				Double tmp = (Double) f_sb.getData();
 				Float data = new Float(tmp.floatValue());
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null, null);
 			} else if (f_sb.getType().equals("java.lang.Float")) {
 				Float data = (Float) f_sb.getData();
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null, null);
 			} else if (f_sb.getType().equals("java.lang.Long")) {
 				Long temp = (Long) f_sb.getData();
 				Float data = new Float(temp.floatValue());
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null);
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null, null);
 			} else if (f_sb.getType().equals("java.lang.Integer")) {
 				Integer temp = (Integer) f_sb.getData();
 				Float data = new Float(temp.floatValue());
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), data, null, null);				
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, data, null, null);				
 			} else {
 				logger.error ("ERROR - found type of " + f_sb.getType() + " for " + f_sb.getAttribute());
 				return;
@@ -136,19 +139,23 @@
 		} else if (attr.getAttribute().matches("State")) {
 			if (f_sb.getType().equals("int")) {
 				Integer tmp = (Integer) f_sb.getData();
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, tmp.toString());			
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, null, tmp.toString());			
 			}
 		} else {
 			if (f_sb.getType().equals("java.lang.String")) {
 				String data = (String) f_sb.getData();
-				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, data);			
+				jmxd = new JMXData(null, f_sb.getServer(), f_sb.getCollectionTime(), null, null, null, data);			
 			} else {
 				logger.error ("ERROR - found type of " + f_sb.getType() + " for " + f_sb.getAttribute());
 				return;
 			} 
 		}
 		
-
+		// If the text value is greater than 2000 characters, do not insert
+		if ((jmxd != null) && (jmxd.getTextvalue() != null) && (jmxd.getTextvalue().length() > 2000)) {
+			return;
+		}
+		
 		jmxd.setAttribute(attr);
 		try {
 			sess.save(jmxd);