vitalif
/
openesb-standalone
mirror of https://github.com/vitalif/openesb-standalone
1
0
Fork 0
Code Issues Releases Wiki Activity

Add MBean for datasources

master
David BRASSELY 2014-02-06 15:40:11 +01:00
parent d43c830999
commit e870cf79d4
2 changed files with 31 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openesb-standalone-framework/src/main/java/net/openesb/standalone/framework/JSEJBIFramework.java
View File

@ -153,7 +153,7 @@ public class JSEJBIFramework
this.init();
// Register a management MBean for this framework instance
ObjectName fwMBeanName = new ObjectName("com.sun.jbi.jse",
ObjectName fwMBeanName = new ObjectName("net.open-esb.standalone",
"instance", mPlatformContext.getInstanceName());
MBeanServer mbs = mPlatformContext.getMBeanServer();
if (mbs.isRegistered(fwMBeanName)) {

35
openesb-standalone-naming/src/main/java/net/openesb/standalone/naming/jndi/tomcat/TomcatDataSourcePoolFactory.java
View File

@ -11,6 +11,8 @@ import java.util.ResourceBundle;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.management.MBeanServer;
import javax.management.ObjectName;
import javax.sql.DataSource;
import javax.sql.XADataSource;
import javax.xml.bind.JAXBElement;
@ -51,15 +53,37 @@ public class TomcatDataSourcePoolFactory implements DataSourcePoolFactory {
*/
public DataSource getDataSource(DataSourcePoolPropertiesComplexType dspProperties) {
PoolProperties poolProperties = this.createNativeDataSource(dspProperties);
return new org.apache.tomcat.jdbc.pool.DataSource(poolProperties);
org.apache.tomcat.jdbc.pool.DataSource ds = new org.apache.tomcat.jdbc.pool.DataSource(poolProperties);
ds.setName(dspProperties.getDbConnectorName());
registerMBean(ds);
return ds;
}
@Override
public XADataSource getXADataSource(DataSourcePoolPropertiesComplexType dspProperties) {
PoolProperties poolProperties = this.createNativeDataSource(dspProperties);
return new org.apache.tomcat.jdbc.pool.XADataSource(poolProperties);
org.apache.tomcat.jdbc.pool.XADataSource ds = new org.apache.tomcat.jdbc.pool.XADataSource(poolProperties);
ds.setName(dspProperties.getDbConnectorName());
registerMBean(ds);
return ds;
}
private void registerMBean(org.apache.tomcat.jdbc.pool.DataSource ds) {
try {
ds.createPool();
ds.setJmxEnabled(true);
MBeanServer mBeanServer = java.lang.management.ManagementFactory.getPlatformMBeanServer();
mBeanServer.registerMBean(ds.getPool().getJmxPool(), new ObjectName("net.open-esb.standalone",
"datasources", ds.getName()));
} catch (Exception e) {
e.printStackTrace();
}
}
private PoolProperties createNativeDataSource(DataSourcePoolPropertiesComplexType dspProperties) {
String methodName = "createNativeDataSource";
@ -158,7 +182,7 @@ public class TomcatDataSourcePoolFactory implements DataSourcePoolFactory {
}
}
}
/* Datasouce fields are set with data proterties found in the context
* Now let's set the pool with the pool proterties found in the context
* get the properties for the pool */
@ -233,7 +257,8 @@ public class TomcatDataSourcePoolFactory implements DataSourcePoolFactory {
}
// set the pool and get a Poolled Datasource
poolProperties.setDataSource(nativeDS);
poolProperties.setJmxEnabled(true);
return poolProperties;
}