Author: indika
Date: Wed Mar 25 09:08:21 2009
New Revision: 758182
URL: http://svn.apache.org/viewvc?rev=758182&view=rev
Log:
add few mwthods to StatisticsView MBean
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/StatisticsReporter.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsView.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsViewMBean.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/StatisticsReporter.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/StatisticsReporter.java?rev=758182&r1=758181&r2=758182&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/StatisticsReporter.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/StatisticsReporter.java
Wed Mar 25 09:08:21 2009
@@ -67,9 +67,12 @@
* @param synCtx Current Message through synapse
*/
public static void reportForAll(MessageContext synCtx) {
+
AspectConfiguration configuration =
AspectConfigurationDetectionStrategy.getAspectConfiguration(synCtx);
+
if (configuration != null && configuration.isStatisticsEnable()) {
+
StatisticsRecord statisticsRecord =
StatisticsReporter.getStatisticsRecord(synCtx);
statisticsRecord.collect(configuration, ComponentType.ANY,
synCtx.isResponse());
StatisticsCollector collector = getStatisticsCollector(synCtx);
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsView.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsView.java?rev=758182&r1=758181&r2=758182&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsView.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsView.java
Wed Mar 25 09:08:21 2009
@@ -56,6 +56,21 @@
ComponentType.PROXYSERVICE, systemViewStrategy));
}
+ public List<String> getSystemEndpointsStats() {
+ return getAllStatsAsList(
+ this.collector.getStatistics(ComponentType.ENDPOINT,
systemViewStrategy));
+ }
+
+ public List<String> getSystemSequncesStats() {
+ return getAllStatsAsList(
+ this.collector.getStatistics(ComponentType.SEQUENCE,
systemViewStrategy));
+ }
+
+ public List<String> getSystemProxyServicesStats() {
+ return getAllStatsAsList(
+ this.collector.getStatistics(ComponentType.PROXYSERVICE,
systemViewStrategy));
+ }
+
public void clearAllStatistics() {
this.collector.clearStatistics();
}
@@ -69,4 +84,12 @@
}
return returnList;
}
+
+ private List<String> getAllStatsAsList(Map<String, Map<String,
InOutStatisticsView>> statsMap) {
+ List<String> tobeReturn = new ArrayList<String>();
+ for (Map<String, InOutStatisticsView> viewMap : statsMap.values()) {
+ tobeReturn.addAll(getAsList(viewMap));
+ }
+ return tobeReturn;
+ }
}
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsViewMBean.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsViewMBean.java?rev=758182&r1=758181&r2=758182&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsViewMBean.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/mbean/StatisticsViewMBean.java
Wed Mar 25 09:08:21 2009
@@ -31,5 +31,11 @@
List<String> getSystemProxyServiceStats(String id);
+ List<String> getSystemEndpointsStats();
+
+ List<String> getSystemSequncesStats();
+
+ List<String> getSystemProxyServicesStats();
+
void clearAllStatistics();
}