[teiid-commits] teiid SVN: r972 - in trunk/embedded/src/main/java/com/metamatrix/dqp/embedded: services and 1 other directory.

[teiid-commits at lists.jboss.org]

Author: vhalbert at redhat.com
Date: 2009-05-18 14:31:12 -0400 (Mon, 18 May 2009)
New Revision: 972

Modified:
   trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java
   trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/services/EmbeddedDataService.java
Log:
Teiid-580 - adding support for monitoring connector connection pools - exposing the stats in embedded

Modified: trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java
===================================================================
--- trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java	2009-05-18 18:30:50 UTC (rev 971)
+++ trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java	2009-05-18 18:31:12 UTC (rev 972)
@@ -370,7 +370,13 @@
 	@Override
 	public Collection getConnectionPoolStats(String identifier)
 			throws AdminException {
-		return Collections.EMPTY_LIST;
+		
+		try {
+			return this.getDataService().getConnectionPoolStatistics(identifier);
+		} catch (MetaMatrixComponentException e) {
+			throw new AdminComponentException(e);
+		}
+
 	}
     
     

Modified: trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/services/EmbeddedDataService.java
===================================================================
--- trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/services/EmbeddedDataService.java	2009-05-18 18:30:50 UTC (rev 971)
+++ trunk/embedded/src/main/java/com/metamatrix/dqp/embedded/services/EmbeddedDataService.java	2009-05-18 18:31:12 UTC (rev 972)
@@ -198,9 +198,24 @@
             }
         }
         throw new ComponentNotFoundException(DQPEmbeddedPlugin.Util.getString("DataService.Unable_to_find_connector_manager_for_{0}_1", new Object[] { connectorBindingName })); //$NON-NLS-1$
-    }    
+    }  
     
     /** 
+     * @see com.metamatrix.dqp.service.DataService#getConnectionPoolStatistics(java.lang.String)
+     * @since 6.1
+     */
+    public Collection getConnectionPoolStatistics(String connectorBindingName) throws MetaMatrixComponentException {
+    	ConnectorBinding binding = getConnectorBinding(connectorBindingName);
+        if (binding != null) {
+            ConnectorManager mgr = getConnectorManager(binding);
+            if (mgr != null ) {  
+            	return mgr.getConnectionPoolStats();
+            }
+        }
+        throw new ComponentNotFoundException(DQPEmbeddedPlugin.Util.getString("DataService.Unable_to_find_connector_manager_for_{0}_1", new Object[] { connectorBindingName })); //$NON-NLS-1$
+    }     
+    
+    /** 
      * @see com.metamatrix.dqp.service.DataService#clearConnectorBindingCache(java.lang.String)
      * @since 4.3
      */