Author: indika
Date: Fri Oct  3 02:33:09 2008
New Revision: 22217
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=22217

Log:
fix compilation error ...

Modified:
   trunk/esb/java/modules/core/src/main/java/org/wso2/esb/ServiceBusManager.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/EndpointAdmin.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/SequenceAdmin.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ServiceAdmin.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/StatisticsReporterThread.java
   
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/persistence/StatisticsDBUtils.java
   trunk/esb/java/pom.xml

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/ServiceBusManager.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/ServiceBusManager.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/ServiceBusManager.java   
    (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/ServiceBusManager.java   
    Fri Oct  3 02:33:09 2008
@@ -28,13 +28,13 @@
 import org.apache.axis2.description.TransportOutDescription;
 import org.apache.axis2.transport.TransportListener;
 import org.apache.axis2.transport.TransportSender;
+import org.apache.axis2.transport.base.ManagementSupport;
 import org.apache.axis2.AxisFault;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.derby.drda.NetworkServerControl;
 import org.apache.synapse.ServerManager;
 import org.apache.synapse.SynapseConstants;
-import org.apache.synapse.transport.base.ManagementSupport;
 import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.core.SynapseEnvironment;
 import org.apache.synapse.registry.Registry;

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/EndpointAdmin.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/EndpointAdmin.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/EndpointAdmin.java
  (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/EndpointAdmin.java
  Fri Oct  3 02:33:09 2008
@@ -25,6 +25,7 @@
 import org.apache.commons.logging.LogFactory;
 import org.apache.synapse.SynapseConstants;
 import org.apache.synapse.SynapseException;
+import org.apache.synapse.audit.AuditConfigurable;
 import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.config.xml.SynapseXMLConfigurationFactory;
 import org.apache.synapse.config.xml.XMLConfigConstants;
@@ -92,12 +93,8 @@
     public void enableStatistics(String endpointName) throws AxisFault {
         try {
             Endpoint ep = 
getSynapseConfiguration().getEndpoint(endpointName.trim());
-            if (ep instanceof AddressEndpoint) {
-                ((AddressEndpoint) ep).getEndpoint()
-                        .setStatisticsState(SynapseConstants.STATISTICS_ON);
-            } else if (ep instanceof WSDLEndpoint) {
-                ((WSDLEndpoint) ep).getEndpoint()
-                        .setStatisticsState(SynapseConstants.STATISTICS_ON);
+            if (ep instanceof AuditConfigurable) {
+                ((AuditConfigurable)ep).enableStatistics();
             } else {
                 handleFault(log, "Selected endpoint : " + endpointName +
                         " does not support statistics", null);
@@ -116,12 +113,8 @@
     public void disableStatistics(String endpointName) throws AxisFault {
         try {
             Endpoint ep = 
getSynapseConfiguration().getEndpoint(endpointName.trim());
-            if (ep instanceof AddressEndpoint) {
-                ((AddressEndpoint) ep).getEndpoint()
-                        .setStatisticsState(SynapseConstants.STATISTICS_OFF);
-            } else if (ep instanceof WSDLEndpoint) {
-                ((WSDLEndpoint) ep).getEndpoint()
-                        .setStatisticsState(SynapseConstants.STATISTICS_OFF);
+            if (ep instanceof AuditConfigurable) {
+                ((AuditConfigurable)ep).disableStatistics();
             } else {
                 handleFault(log, "Selected endpoint : " + endpointName +
                         " does not support statistics", null);
@@ -166,7 +159,8 @@
                     data.setName(ep.getName());
                     data.setType(ADDRESS_EP);
                     EndpointDefinition def = ((AddressEndpoint) 
ep).getEndpoint();
-                    if (def.getStatisticsState() == 
SynapseConstants.STATISTICS_ON) {
+                    if (((AuditConfigurable)ep).isStatisticsEnable()) {
+                
                         data.setEnableStatistics(true);
                     } else {
                         data.setEnableStatistics(false);
@@ -178,7 +172,7 @@
                     data.setName(ep.getName());
                     data.setType(WSDL_EP);
                     EndpointDefinition def = ((WSDLEndpoint) ep).getEndpoint();
-                    if (def.getStatisticsState() == 
SynapseConstants.STATISTICS_ON) {
+                    if (((AuditConfigurable)ep).isStatisticsEnable()) {
                         data.setEnableStatistics(true);
                     } else {
                         data.setEnableStatistics(false);
@@ -421,13 +415,9 @@
                     "The endpoint named '" + endpointName + "' does not 
exist", null);
             }
 
-            int staisticsState = SynapseConstants.STATISTICS_UNSET;
-            if (previousEndpoint instanceof AddressEndpoint) {
-                staisticsState = ((AddressEndpoint) 
previousEndpoint).getEndpoint()
-                    .getStatisticsState();
-            } else if (previousEndpoint instanceof WSDLEndpoint) {
-                staisticsState = ((WSDLEndpoint) 
previousEndpoint).getEndpoint()
-                    .getStatisticsState();
+            boolean staisticsState = false;
+            if (previousEndpoint instanceof AuditConfigurable) {
+                staisticsState = ((AuditConfigurable) 
previousEndpoint).isStatisticsEnable();
             }
 
             Endpoint endpoint = 
EndpointFactory.getEndpointFromElement(endpointElement, false);
@@ -435,12 +425,10 @@
                 handleFault(log, "Newly created endpoint is null ", null);
             }
 
-            if (endpoint instanceof AddressEndpoint) {
-                ((AddressEndpoint) endpoint).getEndpoint()
-                    .setStatisticsState(staisticsState);
-            } else if (endpoint instanceof WSDLEndpoint) {
-                ((WSDLEndpoint) endpoint).getEndpoint()
-                    .setStatisticsState(staisticsState);
+            if (endpoint instanceof AuditConfigurable) {
+                if (staisticsState) {
+                    ((AuditConfigurable) endpoint).enableStatistics();
+                }
             }
 
             getSynapseConfiguration().addEndpoint(endpointName.trim(), 
endpoint);

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
      (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
      Fri Oct  3 02:33:09 2008
@@ -70,11 +70,7 @@
                     data.setTarget(proxy.getTargetEndpoint());
                 }
                 data.setRunning(proxy.isRunning());
-                if(proxy.getStatisticsState() == 
SynapseConstants.STATISTICS_ON) {
-                    data.setEnableStatistics(true);
-                } else {
-                    data.setEnableStatistics(false);
-                }
+               //TODO statistics 
                 if(proxy.getTraceState() == SynapseConstants.TRACING_ON) {
                     data.setEnableTracing(true);
                 } else {
@@ -117,8 +113,7 @@
     public void enableStatistics(String proxyName) throws AxisFault {
 
         try {
-            getSynapseConfiguration().getProxyService(
-                    
proxyName).setStatisticsState(SynapseConstants.STATISTICS_ON);
+            //TODO
             log.info("Enabled statistics on proxy service : " + proxyName);
         } catch (SynapseException syne) {
             handleFault(log, "Unable to enable statistics for proxy service " 
+ proxyName, syne);
@@ -136,8 +131,7 @@
     public void disableStatistics(String proxyName) throws AxisFault {
 
         try {
-            getSynapseConfiguration().getProxyService(
-                    
proxyName).setStatisticsState(SynapseConstants.STATISTICS_OFF);
+           //TODO
             log.info("Disabled statistics on proxy service : " + proxyName);
         } catch (SynapseException syne) {
             handleFault(log, "Unable to disable statistics for proxy service " 
+ proxyName, syne);

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/SequenceAdmin.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/SequenceAdmin.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/SequenceAdmin.java
  (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/SequenceAdmin.java
  Fri Oct  3 02:33:09 2008
@@ -27,6 +27,7 @@
 import org.apache.synapse.SynapseException;
 import org.apache.synapse.Mediator;
 import org.apache.synapse.ManagedLifecycle;
+import org.apache.synapse.audit.AuditConfigurable;
 import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.config.xml.MediatorFactoryFinder;
 import org.apache.synapse.config.xml.MediatorSerializerFinder;
@@ -67,7 +68,7 @@
                 SequenceMediator seqMediator = (SequenceMediator) obj;
                 SequenceData data = new SequenceData();
                 data.setName(seqMediator.getName());
-                if(seqMediator.getStatisticsState() == 
SynapseConstants.STATISTICS_ON) {
+                if(seqMediator.isStatisticsEnable()) {
                     data.setEnableStatistics(true);
                 } else {
                     data.setEnableStatistics(false);
@@ -122,8 +123,8 @@
      */
     public void enableStatistics(String sequenceName) throws AxisFault {
         try {
-            ((SequenceMediator)getSynapseConfiguration().getSequence(
-                    
sequenceName)).setStatisticsState(SynapseConstants.STATISTICS_ON);
+            ((AuditConfigurable)getSynapseConfiguration().getSequence(
+                    sequenceName)).enableStatistics();
             log.info("Enabled statistics on sequence : " + sequenceName);
         } catch (SynapseException syne) {
             handleFault(log,
@@ -138,8 +139,8 @@
      */
     public void disableStatistics(String sequenceName) throws AxisFault {
         try {
-            ((SequenceMediator)getSynapseConfiguration().getSequence(
-                    
sequenceName)).setStatisticsState(SynapseConstants.STATISTICS_OFF);
+            ((AuditConfigurable)getSynapseConfiguration().getSequence(
+                    sequenceName)).disableStatistics();
             log.info("Disabled statistics on sequence : " + sequenceName);
         } catch (SynapseException syne) {
             handleFault(log,

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ServiceAdmin.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ServiceAdmin.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ServiceAdmin.java
   (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/services/ServiceAdmin.java
   Fri Oct  3 02:33:09 2008
@@ -21,6 +21,7 @@
 
 import org.apache.log4j.Logger;
 import org.apache.synapse.SynapseConstants;
+import org.apache.synapse.audit.statistics.StatisticsLog;
 import org.wso2.esb.ServiceBusException;
 import org.wso2.esb.ServiceBusConstants;
 import org.wso2.esb.persistence.PersistenceManager;
@@ -64,9 +65,9 @@
     private StatisticsData getMessageMediationData(String serverId) {
 
         StatisticsData statisticsData = new StatisticsData();
-        statisticsData.setCategory(SynapseConstants.PROXYSERVICE_STATISTICS);
+        statisticsData.setCategory(StatisticsLog.PROXY_SERVICE_STATISTICS);
         statisticsData.setStatisticsRecords(StatisticsDBUtils.getStatistics(
-            pm, serverId, SynapseConstants.PROXYSERVICE_STATISTICS
+            pm, serverId, StatisticsLog.PROXY_SERVICE_STATISTICS
             , SynapseConstants.SYNAPSE_SERVICE_NAME));
         return statisticsData;
     }
@@ -90,9 +91,9 @@
 
     public StatisticsDO[] getSingleServerStatistics(String serverID) throws 
ServiceBusException {
         Object inPSStatisticsSummary = StatisticsDBUtils
-            .getSummaryStatisticsForServer(pm, serverID, 0, 
SynapseConstants.PROXYSERVICE_STATISTICS);
+            .getSummaryStatisticsForServer(pm, serverID, 0, 
StatisticsLog.PROXY_SERVICE_STATISTICS);
         Object outStatisticsSummary = StatisticsDBUtils
-            .getSummaryStatisticsForServer(pm, serverID, 1, 
SynapseConstants.PROXYSERVICE_STATISTICS);
+            .getSummaryStatisticsForServer(pm, serverID, 1, 
StatisticsLog.PROXY_SERVICE_STATISTICS);
         StatisticsDO[] statisticsDOs = null;
         StatisticsDO inStatisticsDO = null;
         StatisticsDO ouStatisticsDO = null;
@@ -141,7 +142,7 @@
     }
 
     public String[] listSequence() throws ServiceBusException {
-        Object namesObject = StatisticsDBUtils.getUniqueNames(pm, 
SynapseConstants.SEQUENCE_STATISTICS);
+        Object namesObject = StatisticsDBUtils.getUniqueNames(pm, 
StatisticsLog.MEDIATOR_STATISTICS);
         String[] names = new String[0];
         if (namesObject instanceof List) {
             List idObjects = (List) namesObject;
@@ -157,7 +158,7 @@
 
     public String[] listProxyServices() throws ServiceBusException {
         Object namesObject = StatisticsDBUtils.getUniqueNames(pm
-            , SynapseConstants.PROXYSERVICE_STATISTICS);
+            , StatisticsLog.PROXY_SERVICE_STATISTICS);
         String[] names = new String[0];
         if (namesObject instanceof List) {
             List idObjects = (List) namesObject;
@@ -185,13 +186,13 @@
     public GraphData getDataForGraph() throws ServiceBusException {
         GraphData graphData = new GraphData();
         List serverData = StatisticsDBUtils.getTotalCountForServerS(pm
-            , SynapseConstants.PROXYSERVICE_STATISTICS);
+            , StatisticsLog.PROXY_SERVICE_STATISTICS);
         List psData = StatisticsDBUtils.getTotalCountForCategory(pm
-            , SynapseConstants.PROXYSERVICE_STATISTICS);
+            , StatisticsLog.PROXY_SERVICE_STATISTICS);
         List epData = StatisticsDBUtils.getTotalCountForCategory(pm
-            , SynapseConstants.ENDPOINT_STATISTICS);
+            , StatisticsLog.ENDPOINT_STATISTICS);
         List sequenceData = StatisticsDBUtils.getTotalCountForCategory(pm
-            , SynapseConstants.SEQUENCE_STATISTICS);
+            , StatisticsLog.ENDPOINT_STATISTICS);
         String serverDataStr = "";
         String psDataStr = "";
         String epDataStr = "";
@@ -226,7 +227,7 @@
 
     public String[] listEndPoint() throws ServiceBusException {
         Object namesObject = StatisticsDBUtils.getUniqueNames(pm
-            , SynapseConstants.ENDPOINT_STATISTICS);
+            , StatisticsLog.ENDPOINT_STATISTICS);
         String[] names = new String[0];
         if (namesObject instanceof List) {
             List idObjects = (List) namesObject;
@@ -241,7 +242,7 @@
     }
 
     public StatisticsData getServerProxyStatistics(String serverID) throws 
ServiceBusException {
-        StatisticsData statisticsData = 
getData(SynapseConstants.PROXYSERVICE_STATISTICS, serverID);
+        StatisticsData statisticsData = 
getData(StatisticsLog.PROXY_SERVICE_STATISTICS, serverID);
         StatisticsDO[] resultSet = statisticsData.getStatisticsRecords();
         List resultList = new ArrayList();
         
@@ -259,23 +260,23 @@
     }
 
     public StatisticsDO[] getProxyServiceStatistics(String proxyName) throws 
ServiceBusException {
-        return getRecords(SynapseConstants.PROXYSERVICE_STATISTICS, proxyName);
+        return getRecords(StatisticsLog.PROXY_SERVICE_STATISTICS, proxyName);
     }
 
     public StatisticsData getServerSequenceStatistics(String serverID) throws 
ServiceBusException {
-        return getData(SynapseConstants.SEQUENCE_STATISTICS, serverID);
+        return getData(StatisticsLog.ENDPOINT_STATISTICS, serverID);
     }
 
     public StatisticsDO[] getSequenceStatistics(String sequenceName) throws 
ServiceBusException {
-        return getRecords(SynapseConstants.SEQUENCE_STATISTICS, sequenceName);
+        return getRecords(StatisticsLog.ENDPOINT_STATISTICS, sequenceName);
     }
 
     public StatisticsData getServerEndPointStatistics(String serverID) throws 
ServiceBusException {
-        return getData(SynapseConstants.ENDPOINT_STATISTICS, serverID);
+        return getData(StatisticsLog.ENDPOINT_STATISTICS, serverID);
     }
 
     public StatisticsDO[] getEndPointStatistics(String endPointName) throws 
ServiceBusException {
-        return getRecords(SynapseConstants.ENDPOINT_STATISTICS, endPointName);
+        return getRecords(StatisticsLog.ENDPOINT_STATISTICS, endPointName);
     }
 
     public StatisticsData getServerMessageMediationStatistics(String serverID) 
throws ServiceBusException {
@@ -284,13 +285,13 @@
 
     public StatisticsDO[] getSingleStatistics(String name, int type) throws 
ServiceBusException {
         switch (type) {
-            case SynapseConstants.SEQUENCE_STATISTICS: {
+            case StatisticsLog.MEDIATOR_STATISTICS: {
                 return getSequenceStatistics(name);
             }
-            case SynapseConstants.ENDPOINT_STATISTICS: {
+            case StatisticsLog.ENDPOINT_STATISTICS: {
                 return getEndPointStatistics(name);
             }
-            case SynapseConstants.PROXYSERVICE_STATISTICS: {
+            case StatisticsLog.PROXY_SERVICE_STATISTICS: {
                 return getProxyServiceStatistics(name);
             }
             default: {

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/StatisticsReporterThread.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/StatisticsReporterThread.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/StatisticsReporterThread.java
     (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/StatisticsReporterThread.java
     Fri Oct  3 02:33:09 2008
@@ -21,8 +21,7 @@
 
 import org.apache.log4j.Logger;
 import org.apache.synapse.core.SynapseEnvironment;
-import org.apache.synapse.statistics.StatisticsCollector;
-import org.apache.synapse.statistics.StatisticsHolder;
+import org.apache.synapse.audit.statistics.StatisticsCollector;
 import org.wso2.esb.persistence.PersistenceManager;
 import org.wso2.esb.statistics.persistence.StatisticsDBUtils;
 import org.wso2.esb.util.HibernateConfigCache;
@@ -100,49 +99,7 @@
                     log.warn("Unable to get hostname or IP address", e);
                 }
                 // report sequence statistics to database
-                Map seqMap = new HashMap();
-                seqMap.putAll(statisticsCollector.getSequenceStatistics());
-                statisticsCollector.resetSequenceStatistics();
-                for (Iterator sequenceStatistics = seqMap.values().iterator();
-                     sequenceStatistics.hasNext();) {
-
-                    Object statisticsHolderObject = sequenceStatistics.next();
-                    if (statisticsHolderObject instanceof StatisticsHolder) {
-                        StatisticsHolder statisticsHolder =
-                            (StatisticsHolder) statisticsHolderObject;
-                        StatisticsDBUtils.updateRecord(pm, ipAddr, 
statisticsHolder);
-                        statisticsHolder.clearStatistics();
-                    }
-                }
-                // report proxy service statistics to database
-                Map proxyMap = new HashMap();
-                
proxyMap.putAll(statisticsCollector.getProxyServiceStatistics());
-                statisticsCollector.resetProxyServiceStatistics();
-                for (Iterator psStats = proxyMap.values().iterator(); 
psStats.hasNext();) {
-
-                    Object statisticsHolderObject = psStats.next();
-                    if (statisticsHolderObject instanceof StatisticsHolder) {
-                        StatisticsHolder statisticsHolder =
-                            (StatisticsHolder) statisticsHolderObject;
-                        StatisticsDBUtils.updateRecord(pm, ipAddr, 
statisticsHolder);
-                        statisticsHolder.clearStatistics();
-                    }
-                }
-                // report end point statistics to database
-                Map epMap = new HashMap();
-                epMap.putAll(statisticsCollector.getEndPointStatistics());
-                statisticsCollector.resetEndPointStatistics();
-                for (Iterator endPointStatistics = epMap.values().iterator();
-                     endPointStatistics.hasNext();) {
-
-                    Object statisticsHolderObject = endPointStatistics.next();
-                    if (statisticsHolderObject instanceof StatisticsHolder) {
-                        StatisticsHolder statisticsHolder =
-                            (StatisticsHolder) statisticsHolderObject;
-                        StatisticsDBUtils.updateRecord(pm, ipAddr, 
statisticsHolder);
-                        statisticsHolder.clearStatistics();
-                    }
-                }
+                //TODO add new statistics impl 
             }
 
             try {

Modified: 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/persistence/StatisticsDBUtils.java
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/persistence/StatisticsDBUtils.java?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/persistence/StatisticsDBUtils.java
        (original)
+++ 
trunk/esb/java/modules/core/src/main/java/org/wso2/esb/statistics/persistence/StatisticsDBUtils.java
        Fri Oct  3 02:33:09 2008
@@ -19,11 +19,11 @@
 
 package org.wso2.esb.statistics.persistence;
 
-import org.apache.synapse.statistics.Statistics;
-import org.apache.synapse.statistics.StatisticsHolder;
+
 import org.wso2.esb.persistence.PersistenceManager;
 import org.wso2.esb.persistence.dataobject.StatisticsDO;
 import org.wso2.esb.ServiceBusConstants;
+import org.apache.synapse.audit.statistics.view.Statistics;
 
 import java.util.List;
 
@@ -61,22 +61,11 @@
      *
      * @param pm
      * @param serverId
-     * @param statisticsHolder
      * @
      */
-    public static void insertRecord(PersistenceManager pm, String serverId,
-                                    StatisticsHolder statisticsHolder) {
+    public static void insertRecord(PersistenceManager pm, String serverId) {
 
-        String key = statisticsHolder.getKey();
-        int statisticsCategory = statisticsHolder.getStatisticsCategory();
-        if (statisticsHolder.getInFlowStatistics() != null) {
-            pm.addStatisticsRecord(createStatisticsRecord(
-                serverId, statisticsCategory, key, 0, 
statisticsHolder.getInFlowStatistics()));
-        }
-        if (statisticsHolder.getOutFlowStatistics() != null) {
-            pm.addStatisticsRecord(createStatisticsRecord(
-                serverId, statisticsCategory, key, 1, 
statisticsHolder.getOutFlowStatistics()));
-        }
+        //TODO
     }
 
     /**
@@ -84,22 +73,11 @@
      *
      * @param pm
      * @param serverId
-     * @param statisticsHolder
      * @
      */
-    public static void updateRecord(PersistenceManager pm, String serverId,
-                                    StatisticsHolder statisticsHolder) {
+    public static void updateRecord(PersistenceManager pm, String serverId) {
 
-        String key = statisticsHolder.getKey();
-        int statisticsCategory = statisticsHolder.getStatisticsCategory();
-        if (statisticsHolder.getInFlowStatistics() != null) {
-            updateRecord(pm, serverId, statisticsCategory,
-                key, 0, statisticsHolder.getInFlowStatistics());
-        }
-        if (statisticsHolder.getOutFlowStatistics() != null) {
-            updateRecord(pm, serverId, statisticsCategory,
-                key, 1, statisticsHolder.getOutFlowStatistics());
-        }
+       //TODO
     }
 
     /**

Modified: trunk/esb/java/pom.xml
URL: 
http://wso2.org/svn/browse/wso2/trunk/esb/java/pom.xml?rev=22217&r1=22216&r2=22217&view=diff
==============================================================================
--- trunk/esb/java/pom.xml      (original)
+++ trunk/esb/java/pom.xml      Fri Oct  3 02:33:09 2008
@@ -795,6 +795,12 @@
             <artifactId>authenticator</artifactId>
             <version>${authenticator.version}</version>
         </dependency>
+        
+        <dependency>
+            <groupId>jaxen</groupId>
+            <artifactId>jaxen</artifactId>
+            <version>${jaxen.version}</version>
+        </dependency>
 
     </dependencies>
 
@@ -925,5 +931,6 @@
         <wrapper.version>3.2.3</wrapper.version>
         <tomcat.version>5.5.15</tomcat.version>
         <geronimo.spec.jta.version>1.0.1B-rc4</geronimo.spec.jta.version>
+        <jaxen.version>1.1.1</jaxen.version>
     </properties>
 </project>

_______________________________________________
Esb-java-dev mailing list
[email protected]
http://mailman.wso2.org/cgi-bin/mailman/listinfo/esb-java-dev

Reply via email to