[jboss-svn-commits] JBL Code SVN: r23574 - labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Oct 24 03:21:33 EDT 2008
Author: tcunning
Date: 2008-10-24 03:21:32 -0400 (Fri, 24 Oct 2008)
New Revision: 23574
Modified:
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounter.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterMBean.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterStatistics.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageStatusBean.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java
Log:
bug:JBESB-2107
Change byte total metrics to long.
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounter.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounter.java 2008-10-24 07:20:46 UTC (rev 23573)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounter.java 2008-10-24 07:21:32 UTC (rev 23574)
@@ -69,11 +69,11 @@
return MessageCounterStatistics.getMessageCounterStatistics().getSuccessfulMessageCount();
}
- public int getProcessedBytes() {
+ public long getProcessedBytes() {
return MessageCounterStatistics.getMessageCounterStatistics().getProcessedBytes();
}
- public int getFailedBytes() {
+ public long getFailedBytes() {
return MessageCounterStatistics.getMessageCounterStatistics().getFailedBytes();
}
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterMBean.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterMBean.java 2008-10-24 07:20:46 UTC (rev 23573)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterMBean.java 2008-10-24 07:21:32 UTC (rev 23574)
@@ -43,7 +43,7 @@
public void resetCounts();
- public int getProcessedBytes();
+ public long getProcessedBytes();
- public int getFailedBytes();
+ public long getFailedBytes();
}
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterStatistics.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterStatistics.java 2008-10-24 07:20:46 UTC (rev 23573)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageCounterStatistics.java 2008-10-24 07:21:32 UTC (rev 23574)
@@ -39,8 +39,8 @@
private int failedMessageCount;
private int successMessageCount;
private long totalProcessTime;
- private int bytesProcessed;
- private int bytesFailed;
+ private long bytesProcessed;
+ private long bytesFailed;
/**
* Constructor.
@@ -89,11 +89,11 @@
return successMessageCount;
}
- public synchronized int getProcessedBytes() {
+ public synchronized long getProcessedBytes() {
return bytesProcessed;
}
- public synchronized int getFailedBytes() {
+ public synchronized long getFailedBytes() {
return bytesFailed;
}
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageStatusBean.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageStatusBean.java 2008-10-24 07:20:46 UTC (rev 23573)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/MessageStatusBean.java 2008-10-24 07:21:32 UTC (rev 23574)
@@ -95,12 +95,12 @@
* Message number of bytes getter
* @return message bytes
*/
- public int getMessageBytes() {
- int messageBytes = 0;
+ public long getMessageBytes() {
+ long messageBytes = 0;
try {
String byteSizeString = (String) this.m_msg.getProperties().getProperty(Environment.MESSAGE_BYTE_SIZE);
if (byteSizeString != null) {
- messageBytes = Integer.parseInt(byteSizeString);
+ messageBytes = Long.parseLong(byteSizeString);
}
} catch (NullPointerException npe) {
}
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-24 07:20:46 UTC (rev 23573)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ServiceMessageCounter.java 2008-10-24 07:21:32 UTC (rev 23574)
@@ -58,8 +58,8 @@
private Hashtable<String, IntHolder> actionCounterHash;
private Hashtable<String, IntHolder> actionFailedCounterHash;
private Hashtable<String, LongHolder> actionProcessTimeHash;
- private Hashtable<String, IntHolder> actionBytesProcessedHash;
- private Hashtable<String, IntHolder> actionBytesFailedHash;
+ private Hashtable<String, LongHolder> actionBytesProcessedHash;
+ private Hashtable<String, LongHolder> actionBytesFailedHash;
private String[] actionNames;
private final ObjectName listObjectName ;
@@ -91,8 +91,8 @@
actionCounterHash = new Hashtable<String, IntHolder>();
actionFailedCounterHash = new Hashtable<String, IntHolder>();
actionProcessTimeHash = new Hashtable<String, LongHolder>();
- actionBytesProcessedHash = new Hashtable<String, IntHolder>();
- actionBytesFailedHash = new Hashtable<String, IntHolder>();
+ actionBytesProcessedHash = new Hashtable<String, LongHolder>();
+ actionBytesFailedHash = new Hashtable<String, LongHolder>();
init(f_config);
ObjectName listObjectName = null ;
@@ -144,13 +144,13 @@
actionCounterHash.put(actionId + " " + MESSAGE_COUNTER, new IntHolder());
actionFailedCounterHash.put(actionId + " " + FAILED_MESSAGE_COUNTER, new IntHolder());
actionProcessTimeHash.put(actionId + " " + PROCESSING_TIME, new LongHolder());
- actionBytesFailedHash.put(actionId + " " + BYTES_FAILED, new IntHolder());
- actionBytesProcessedHash.put(actionId + " " + BYTES_PROCESSED, new IntHolder());
+ actionBytesFailedHash.put(actionId + " " + BYTES_FAILED, new LongHolder());
+ actionBytesProcessedHash.put(actionId + " " + BYTES_PROCESSED, new LongHolder());
actionNames[count] = actionId ;
}
serviceCount = new Integer(0);
- bytesProcessed = new Integer(0);
- bytesFailed = new Integer(0);
+ bytesProcessed = new Long(0);
+ bytesFailed = new Long(0);
}
/**
@@ -175,11 +175,11 @@
}
for (String key : actionBytesFailedHash.keySet()) {
- actionBytesFailedHash.put(key, new IntHolder());
+ actionBytesFailedHash.put(key, new LongHolder());
}
for (String key : actionBytesProcessedHash.keySet()) {
- actionBytesProcessedHash.put(key, new IntHolder());
+ actionBytesProcessedHash.put(key, new LongHolder());
}
}
@@ -218,13 +218,13 @@
for (String key : actionBytesFailedHash.keySet()) {
attrs[counter] = new MBeanAttributeInfo(
- key, "java.lang.Integer", "Property " + key, true, false, false);
+ key, "java.lang.Long", "Property " + key, true, false, false);
counter++;
}
for (String key : actionBytesProcessedHash.keySet()) {
attrs[counter] = new MBeanAttributeInfo(
- key, "java.lang.Integer", "Property " + key, true, false, false);
+ key, "java.lang.Long", "Property " + key, true, false, false);
counter++;
}
@@ -233,12 +233,12 @@
attrs[counter] = overallCount;
counter++;
- MBeanAttributeInfo overallBytesProcessed = new MBeanAttributeInfo(OVERALL_BYTES_PROCESSED, "java.lang.Integer",
+ MBeanAttributeInfo overallBytesProcessed = new MBeanAttributeInfo(OVERALL_BYTES_PROCESSED, "java.lang.Long",
"Property " + OVERALL_BYTES_PROCESSED, true, false, false);
attrs[counter] = overallBytesProcessed;
counter++;
- MBeanAttributeInfo overallBytesFailed = new MBeanAttributeInfo(OVERALL_BYTES_FAILED, "java.lang.Integer",
+ MBeanAttributeInfo overallBytesFailed = new MBeanAttributeInfo(OVERALL_BYTES_FAILED, "java.lang.Long",
"Property " + OVERALL_BYTES_FAILED, true, false, false);
attrs[counter] = overallBytesFailed;
counter++;
@@ -419,7 +419,7 @@
count.value++ ;
LongHolder time = actionProcessTimeHash.get(actionName + " " + PROCESSING_TIME);
time.value += asb.getProcTime();
- IntHolder bProcessed = actionBytesProcessedHash.get(actionName + " " + BYTES_PROCESSED);
+ LongHolder bProcessed = actionBytesProcessedHash.get(actionName + " " + BYTES_PROCESSED);
bProcessed.value += asb.getBytesProcessed();
bytesProcessed += asb.getBytesProcessed();
} else if (ActionStatusBean.ACTION_FAILED.equals(asb.getStatus())) {
@@ -427,7 +427,7 @@
count.value++ ;
LongHolder time = actionProcessTimeHash.get(actionName + " " + PROCESSING_TIME);
time.value += asb.getProcTime();
- IntHolder bFailed = actionBytesFailedHash.get(actionName + " " + BYTES_FAILED);
+ LongHolder bFailed = actionBytesFailedHash.get(actionName + " " + BYTES_FAILED);
bFailed.value += asb.getBytesProcessed();
bytesFailed += asb.getBytesProcessed();
}
More information about the jboss-svn-commits
mailing list