Author: vhalbert(a)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 */