your postconstruct is where you define resources? it is just useless actually. Resources are defined in resources.xml or tomee.xml
all you do with it is to start another container or nothing depending the environment Romain Manni-Bucau Twitter: @rmannibucau Blog: http://rmannibucau.wordpress.com/ LinkedIn: http://fr.linkedin.com/in/rmannibucau Github: https://github.com/rmannibucau 2014-03-16 21:10 GMT+01:00 onyii5119 <[email protected]>: > I did what you are suggesting before posting my request. > > Please find my code and see if you could identify what is wrong with my code > (it is a simple example) > > public class DeterminedRouter extends AbstractRouter implements Serializable > { > private static final long serialVersionUID = -4973022035526665822L; > final Logger log = LoggerFactory.getLogger(this.getClass()); > > private String dataSourceNames; > private String defaultDataSourceName; > private Map<String, DataSource> dataSources = null; > private ThreadLocal<DataSource> currentDataSource = new > ThreadLocal<DataSource>(); > > /** > * > */ > public DeterminedRouter() { > } > > /** > * @param datasourceList datasource resource name, separator is a space > */ > public void setDataSourceNames(String datasourceList) { > dataSourceNames = datasourceList; > } > > /** > * lookup datasource in openejb resources > */ > private void init() { > dataSources = new ConcurrentHashMap<String, DataSource>(); > for (String ds : dataSourceNames.split(" ")) { > try { > Object o = getOpenEJBResource(ds); > if (o instanceof DataSource) { > dataSources.put(ds, DataSource.class.cast(o)); > } > }catch (NamingException e) { > e.printStackTrace(); > } > } > } > > /** > * @return the user selected data source if it is set > * or the default one > * @throws IllegalArgumentException if the data source is not found > */ > @Override > public DataSource getDataSource() { > // lazy init of routed datasources > if (dataSources == null) { > init(); > } > > // if no datasource is selected use the default one > if (currentDataSource.get() == null) { > if (dataSources.containsKey(defaultDataSourceName)) { > return dataSources.get(defaultDataSourceName); > > } else { > throw new IllegalArgumentException("you have to specify at > least one datasource"); > } > } > > // the developper set the datasource to use > return currentDataSource.get(); > } > > /** > * > * @param datasourceName data source name > */ > public void setDataSource(String datasourceName) { > if (dataSources == null) { > init(); > } > if (!dataSources.containsKey(datasourceName)) { > throw new IllegalArgumentException("data source called " + > datasourceName + " can't be found."); > } > DataSource ds = dataSources.get(datasourceName); > currentDataSource.set(ds); > } > > /** > * reset the data source > */ > public void clear() { > currentDataSource.remove(); > } > > public void setDefaultDataSourceName(String name) { > this.defaultDataSourceName = name; > } > > } > > //////////////////////////////////////////////////////////////// > > @Stateless > public class RoutedPersister implements Serializable { > private static final long serialVersionUID = -4630430944530409705L; > final Logger log = LoggerFactory.getLogger(this.getClass()); > > @Resource(name="TsRouter", type = DeterminedRouter.class) > private DeterminedRouter router; > > @PersistenceContext(unitName = "router") > private EntityManager em; > > private RoutedPersister routedPersister; > > private String[] databases; > private Properties properties; > > > /** > * > */ > public RoutedPersister() { > } > > @PostConstruct > public void init(){ > try{ > databases = new String[]{"db1", "db2", "db3"}; > > properties = new Properties(); > properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, > LocalInitialContextFactory.class.getName()); > > // resources > // datasources > for (int i = 1; i <= databases.length; i++) { > String dbName = databases[i - 1]; > properties.setProperty(dbName, > "new://Resource?type=DataSource"); > dbName += "."; > properties.setProperty(dbName + "JdbcDriver", > "com.mysql.jdbc.Driver"); > properties.setProperty(dbName + "JdbcUrl", > "jdbc:mysql://domain.com:3306/" + i); > properties.setProperty(dbName + "UserName", > "username"); > properties.setProperty(dbName + "Password", > "password"); > properties.setProperty(dbName + "JtaManaged", "true"); > } > > // router > properties.setProperty("TsRouter", > "new://Resource?provider=org.router:DeterminedRouter&type=" + > DeterminedRouter.class.getName()); > properties.setProperty("TsRouter.DatasourceNames", "db1 > db2 db3"); > properties.setProperty("TsRouter.DefaultDataSourceName", > "db1"); > > // routed datasource > properties.setProperty("Routed Datasource", > "new://Resource?provider=RoutedDataSource&type=" + Router.class.getName()); > properties.setProperty("Routed Datasource.Router", > "TsRouter"); > > Context ctx = > EJBContainer.createEJBContainer(properties).getContext(); > routedPersister = (RoutedPersister) > ctx.lookup("java:global/dynamic-datasource-routing/RoutedPersister"); > > }catch(Exception e){ > e.printStackTrace(); > } > } > > public RoutedPersister getRoutedPersister() { > return routedPersister; > } > > public void setRoutedPersister(RoutedPersister routedPersister) { > this.routedPersister = routedPersister; > } > > public void persist(int id, String name, String ds) { > router.setDataSource(ds); > // em.persist(new Person(id, name)); > } > > } > > //////////////////////////////////////////////////////////////////////////// > > <?xml version="1.0" encoding="UTF-8"?> > <ServiceJar> > > <ServiceProvider id="TsRouter" > service="Resource" > type="org.apache.openejb.resource.jdbc.Router" > class-name="test.datasources.DeterminedRouter" > > > > # the parameters > > DataSourceNames > DefaultDataSourceName > </ServiceProvider> > </ServiceJar> > > I placed this file in WEB-INF/classes/META-INF/org.router/service-jar.xml > > When I run it I get the following error message: > > Mar 16, 2014 4:07:23 PM org.apache.tomee.catalina.TomcatWebAppBuilder > startInternal > SEVERE: Unable to deploy collapsed ear in war > StandardEngine[Catalina].StandardHost[l > ocalhost].StandardContext[/rls] > org.apache.openejb.OpenEJBException: Can't find resource for class > test.datas > ources.RoutedPersister#router. (No provider available for resource-ref > 'null' of type > 'test.datasources.DeterminedRouter' for 'rls.Comp1509825954'.) > at > org.apache.openejb.config.AutoConfig.processResourceRef(AutoConfig.java:11 > 74) > at org.apache.openejb.config.AutoConfig.deploy(AutoConfig.java:858) > at org.apache.openejb.config.AutoConfig.deploy(AutoConfig.java:193) > at > org.apache.openejb.config.ConfigurationFactory$Chain.deploy(ConfigurationF > actory.java:396) > at > org.apache.openejb.config.ConfigurationFactory.configureApplication(Config > urationFactory.java:938) > at > org.apache.tomee.catalina.TomcatWebAppBuilder.startInternal(TomcatWebAppBu > ilder.java:1171) > at > org.apache.tomee.catalina.TomcatWebAppBuilder.configureStart(TomcatWebAppB > uilder.java:1051) > at > org.apache.tomee.catalina.GlobalListenerSupport.lifecycleEvent(GlobalListe > nerSupport.java:127) > at > org.apache.catalina.util.LifecycleSupport.fireLifecycleEvent(LifecycleSupp > ort.java:119) > at > org.apache.catalina.util.LifecycleBase.fireLifecycleEvent(LifecycleBase.ja > > > > -- > View this message in context: > http://openejb.979440.n4.nabble.com/Dynamic-DataSource-Exception-tp4657657p4668232.html > Sent from the OpenEJB User mailing list archive at Nabble.com.
