[jboss-svn-commits] JBL Code SVN: r7400 - in labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status: common/protocol common/protocol/conf common/tools portlet/conf service/impl service/impl/db/protocol

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Sat Nov 4 13:07:12 EST 2006


Author: wrzep
Date: 2006-11-04 13:07:06 -0500 (Sat, 04 Nov 2006)
New Revision: 7400

Added:
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresUpdater.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresDailyUpdater.java
Removed:
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresUpdater.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ScoresDailyUpdater.java
Modified:
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresService.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresFactory.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/tools/Tools.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresServiceImpl.java
   labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/DBScoresFactory.java
Log:
http://jira.jboss.com/jira/browse/JBLAB-781 (Standalone JMM Service)
Moved auto-updates from labs side to JMM service side.
Pawel


Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresService.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresService.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresService.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -32,6 +32,7 @@
 import org.jboss.forge.status.common.protocol.conf.PluginConf;
 import org.jboss.forge.status.common.protocol.conf.PluginsValues;
 import org.jboss.forge.status.common.protocol.conf.PluginsValuesRemote;
+import org.jboss.forge.status.common.protocol.conf.ServiceConf;
 
 /**
 * @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
@@ -40,7 +41,7 @@
 public interface ScoresService extends Serializable {
 	
 	public void init(String portalName, ScoresManager scoresManager,
-					List<PluginConf> pluginsConf, List<String> projectIds)
+					List<PluginConf> pluginsConf, ServiceConf serviceConf, List<String> projectIds)
 												throws ScoresException;
 	
 	public void save() throws ScoresSaveException;	

Deleted: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresUpdater.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresUpdater.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresUpdater.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -1,36 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.forge.status.common.protocol;
-
-import java.io.Serializable;
-
-import org.jboss.forge.status.common.protocol.conf.ServiceConf;
-
-/**
-* @author Pawel Wrzeszcz (pawel . wrzeszcz [at] jboss . com)
-*/
-public interface ScoresUpdater extends Serializable {
-	
-	public void init(ScoresManager scoresManager, ServiceConf conf);
-	
-}
\ No newline at end of file

Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresFactory.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresFactory.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresFactory.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -22,6 +22,7 @@
 
 package org.jboss.forge.status.common.protocol.conf;
 
+import java.io.Serializable;
 import java.util.List;
 import org.jboss.forge.status.common.tools.Plugins;
 import org.jboss.forge.status.service.plugins.Plugin;
@@ -31,7 +32,7 @@
 * 
 * An abstract factory for creating objects that handle scores.
 */
-public interface ScoresFactory {
+public interface ScoresFactory extends Serializable {
 	
 	public PluginsValues createPluginsValues(List<String> projectIds, Plugins plugins);
 	

Added: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresUpdater.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresUpdater.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ScoresUpdater.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -0,0 +1,36 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.forge.status.common.protocol.conf;
+
+import java.io.Serializable;
+
+import org.jboss.forge.status.common.protocol.ScoresService;
+
+/**
+* @author Pawel Wrzeszcz (pawel . wrzeszcz [at] jboss . com)
+*/
+public interface ScoresUpdater extends Serializable {
+	
+	public void init(ScoresService scoresService, ServiceConf conf);
+	
+}
\ No newline at end of file

Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/tools/Tools.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/tools/Tools.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/tools/Tools.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -8,6 +8,7 @@
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
+import java.util.Properties;
 import java.util.StringTokenizer;
 
 import javax.management.MBeanServer;
@@ -15,6 +16,10 @@
 import javax.management.remote.JMXConnectorServer;
 import javax.management.remote.JMXConnectorServerFactory;
 import javax.management.remote.JMXServiceURL;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import javax.rmi.PortableRemoteObject;
 
 import org.apache.xerces.parsers.DOMParser;
 import org.jboss.forge.common.projects.project.Project;
@@ -22,7 +27,9 @@
 import org.jboss.forge.status.common.Constants;
 import org.jboss.forge.status.common.Tags;
 import org.jboss.forge.status.common.exceptions.InvalidPluginsConfigurationException;
+import org.jboss.forge.status.common.protocol.ScoresService;
 import org.jboss.forge.status.common.protocol.conf.PluginConf;
+import org.jboss.forge.status.common.protocol.conf.ScoresUpdater;
 import org.jboss.forge.status.common.tools.test.TestProject;
 import org.jboss.forge.status.portlet.StatusConfWatcher;
 import org.jboss.forge.status.portlet.StatusDescriptor;
@@ -161,4 +168,48 @@
 		
 		log.info("MBeanRemoteProxy created successfully.");
 	}
+
+	public static ScoresService getScoresService(Properties properties) throws NamingException {	
+		
+		log.info("Security Manager: " + System.getSecurityManager());
+			
+		log.info("InitialContext");
+		InitialContext ic = new InitialContext(properties);
+		    
+		log.info("lookup");
+		ScoresService service = (ScoresService)ic.lookup("JMMService");
+			
+		log.info("ping");
+		log.info("service: " + service.toString());
+		service.ping();
+	
+		return service;
+	}
+		
+	public static ScoresUpdater getScoresUpdater() {
+			
+		ScoresUpdater updater;
+			
+		try {
+			Context context = new InitialContext();
+			
+			//	Perform look up using JNDI name of ejb object
+			String serviceBinding = Constants.DAILY_SCORES_UPDATER;
+				
+			Object ref = context.lookup(serviceBinding);
+				
+			// Narrow the reference of the object returned by lookup() method
+			updater = (ScoresUpdater) PortableRemoteObject.narrow( ref, 
+													ScoresUpdater.class);
+			
+		} catch (NamingException e) {
+			
+			log.warn("Unable to schedule updates." +
+											"\nCause: " + e.getMessage());
+			return null;
+		}
+			
+		
+		return updater;
+	}
 }

Deleted: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ScoresDailyUpdater.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ScoresDailyUpdater.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ScoresDailyUpdater.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -1,110 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.forge.status.portlet.conf;
-
-import java.util.Calendar;
-import javax.annotation.Resource;
-import javax.ejb.Local;
-import javax.ejb.Stateless;
-import javax.ejb.Timeout;
-import javax.ejb.Timer;
-
-import org.jboss.annotation.ejb.LocalBinding;
-
-import org.jboss.forge.status.common.Constants;
-import org.jboss.forge.status.common.exceptions.ScoresSaveException;
-import org.jboss.forge.status.common.protocol.ScoresManager;
-import org.jboss.forge.status.common.protocol.ScoresUpdater;
-import org.jboss.forge.status.common.protocol.conf.ServiceConf;
-
-import org.jboss.logging.Logger;
-
-/**
-* @author Pawel Wrzeszcz (pawel . wrzeszcz [at] jboss . com)
-*/
-
- at Stateless
- at Local(ScoresUpdater.class)
- at LocalBinding(jndiBinding=Constants.DAILY_SCORES_UPDATER)
-public class ScoresDailyUpdater implements ScoresUpdater {
-
-
-	private static final long serialVersionUID = 2272792275281319486L;
-
-	@Resource private javax.ejb.TimerService timerService;
-	
-	private Logger log = Logger.getLogger(ScoresDailyUpdater.class);
-	
-	public void init(ScoresManager scoresManager, ServiceConf conf) {
-	
-		 log.info("INIT ScoresManager: " + scoresManager);
-		
-		clearSchedule();
-		
-		scheduleUpdates(scoresManager, conf);
-	}
-
-	@Timeout
-    public void update(Timer timer) {
-		
-       log.info("Updating scores...");
-       
-       ScoresManager scoresManager = (ScoresManager) timer.getInfo();
-      
-       try {
-    	   		scoresManager.save();
-    	   
-       } catch (ScoresSaveException e) {
-    	   
-    	   		log.warn("Unable to update scores.\nCause: " + e.getMessage());
-       }
-    }
-	
-	private void clearSchedule() {
-    	
-        for (Object obj : timerService.getTimers( )) {
-         
-            Timer timer = (Timer) obj;
-            timer.cancel( );
-        }
-    }
-	
-	private void scheduleUpdates(ScoresManager scoresManager, ServiceConf conf) {
-	
-		if (conf.getFirstUpdate() > 0) {
-		
-			long firstUpdateMills = conf.getFirstUpdate() * 60 * 1000;
-			timerService.createTimer(firstUpdateMills, scoresManager);
-		}
-		
-		long updateIntervalMills = conf.getUpdateInterval() * 60 * 1000;
-		
-		Calendar cal = Calendar.getInstance();
-		cal.add(Calendar.DATE, 1);
-		cal.set(Calendar.HOUR_OF_DAY, conf.getUpdateStartHour());
-		cal.set(Calendar.MINUTE, conf.getUpdateStartMinute());
-		
-		timerService.createTimer(cal.getTime(),
-										updateIntervalMills, scoresManager);
-	}
-}

Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -22,9 +22,7 @@
 
 package org.jboss.forge.status.portlet.conf;
 
-import java.rmi.RMISecurityManager;
-import java.security.AccessControlContext;
-import java.security.AccessController;
+
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.List;
@@ -46,10 +44,10 @@
 
 import org.jboss.forge.status.common.protocol.ScoresManager;
 import org.jboss.forge.status.common.protocol.ScoresService;
-import org.jboss.forge.status.common.protocol.ScoresUpdater;
 import org.jboss.forge.status.common.protocol.conf.PluginConf;
 import org.jboss.forge.status.common.protocol.conf.PluginsValues;
 import org.jboss.forge.status.common.protocol.conf.PluginsValuesRemote;
+import org.jboss.forge.status.common.protocol.conf.ScoresUpdater;
 import org.jboss.forge.status.common.protocol.conf.ServiceConf;
 
 import org.jboss.forge.status.common.tools.Tools;
@@ -85,7 +83,7 @@
 		log = Logger.getLogger(this.getClass());
 		
 		try {			
-			service = getService();
+			service = Tools.getScoresService(properties);
 		} catch (NamingException e) {
 			throw new ScoresException(e);
 		}
@@ -94,9 +92,7 @@
 				projects.getProjectIds(
 						(PermissionsChecker) new NullPermissionsChecker(), null));
 		
-		service.init(portalName, this, pluginsConf, projectIds);
-		
-		sheduleUpdates(serviceConf);
+		service.init(portalName, this, pluginsConf, serviceConf, projectIds);
 	}
 	
 	public void saveAsync(final Projects projects,
@@ -224,70 +220,4 @@
 		
 		return service.getValue(pluginId, projectId, start, end);
 	}
-	
-	private ScoresService getService() throws NamingException {
-		
-	//	System.setProperty("java.security.policy", "/home/pawel/moje/JBoss/as/server/all/conf/server.policy");
-		//if (System.getSecurityManager() == null) {
-			
-			//log.info("Set RMISecutiryManager()");
-			//System.setSecurityManager(new SecurityManager());
-		
-
-		log.info("Security Manager: " + System.getSecurityManager());
-		
-		//RemoteMBeanServer lConnector = new RMIClientConnectorImpl("server-name" );
-		
-		log.info("InitialContext");
-		InitialContext ic = new InitialContext(properties);
-        
-		log.info("lookup");
-		ScoresService service = (ScoresService)ic.lookup("JMMService");
-		
-		log.info("ping");
-		log.info("myService: " + service.toString());
-		service.ping();
-		 
-		log.info("return");
-		return service;
-	}
-	
-	private void sheduleUpdates(ServiceConf conf) {
-		
-		ScoresUpdater updater = getScoresUpdater();
-		
-		if (updater != null) {
-			
-			updater.init(this, conf);
-		}
-	}
-
-	//TODO move updater handling to ScoresService
-	private ScoresUpdater getScoresUpdater() {
-				
-		ScoresUpdater updater;
-		
-		try {
-			Context context = new InitialContext();
-		
-			//	Perform look up using JNDI name of ejb object
-			String serviceBinding = Constants.DAILY_SCORES_UPDATER;
-			
-			Object ref = context.lookup(serviceBinding);
-			
-			// Narrow the reference of the object returned by lookup() method
-			updater = (ScoresUpdater) PortableRemoteObject.narrow( ref, 
-													ScoresUpdater.class);
-			
-		} catch (NamingException e) {
-			
-			log.warn("Unable to schedule updates." +
-											"\nCause: " + e.getMessage());
-			return null;
-		}
-		
-		
-		return updater;
-	}
-
 }

Added: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresDailyUpdater.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresDailyUpdater.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresDailyUpdater.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -0,0 +1,110 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.forge.status.service.impl;
+
+import java.util.Calendar;
+import javax.annotation.Resource;
+import javax.ejb.Local;
+import javax.ejb.Stateless;
+import javax.ejb.Timeout;
+import javax.ejb.Timer;
+
+import org.jboss.annotation.ejb.LocalBinding;
+
+import org.jboss.forge.status.common.Constants;
+import org.jboss.forge.status.common.exceptions.ScoresSaveException;
+import org.jboss.forge.status.common.protocol.ScoresService;
+import org.jboss.forge.status.common.protocol.conf.ScoresUpdater;
+import org.jboss.forge.status.common.protocol.conf.ServiceConf;
+
+import org.jboss.logging.Logger;
+
+/**
+* @author Pawel Wrzeszcz (pawel . wrzeszcz [at] jboss . com)
+*/
+
+ at Stateless
+ at Local(ScoresUpdater.class)
+ at LocalBinding(jndiBinding=Constants.DAILY_SCORES_UPDATER)
+public class ScoresDailyUpdater implements ScoresUpdater {
+
+
+	private static final long serialVersionUID = 2272792275281319486L;
+
+	@Resource private javax.ejb.TimerService timerService;
+	
+	private Logger log = Logger.getLogger(ScoresDailyUpdater.class);
+	
+	public void init(ScoresService scoresService, ServiceConf conf) {
+	
+		log.info("ScoresDailyUpdater initialization");
+		
+		clearSchedule();
+		
+		scheduleUpdates(scoresService, conf);
+	}
+
+	@Timeout
+    public void update(Timer timer) {
+		
+       log.info("Updating scores...");
+       
+       ScoresService scoresService = (ScoresService) timer.getInfo();
+      
+       try {
+    	   		scoresService.save();
+    	   
+       } catch (ScoresSaveException e) {
+    	   
+    	   		log.warn("Unable to update scores.\nCause: " + e.getMessage());
+       }
+    }
+	
+	private void clearSchedule() {
+    	
+        for (Object obj : timerService.getTimers( )) {
+         
+            Timer timer = (Timer) obj;
+            timer.cancel( );
+        }
+    }
+	
+	private void scheduleUpdates(ScoresService scoresService, ServiceConf conf) {
+	
+		if (conf.getFirstUpdate() > 0) {
+		
+			long firstUpdateMills = conf.getFirstUpdate() * 60 * 1000;
+			timerService.createTimer(firstUpdateMills, scoresService);
+		}
+		
+		long updateIntervalMills = conf.getUpdateInterval() * 60 * 1000;
+		
+		Calendar cal = Calendar.getInstance();
+		cal.add(Calendar.DATE, 1);
+		cal.set(Calendar.HOUR_OF_DAY, conf.getUpdateStartHour());
+		cal.set(Calendar.MINUTE, conf.getUpdateStartMinute());
+		
+		timerService.createTimer(cal.getTime(),
+										updateIntervalMills, scoresService);
+	}
+}

Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresServiceImpl.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresServiceImpl.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresServiceImpl.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -50,7 +50,10 @@
 import org.jboss.forge.status.common.protocol.conf.PluginsValues;
 import org.jboss.forge.status.common.protocol.conf.PluginsValuesRemote;
 import org.jboss.forge.status.common.protocol.conf.ScoresFactory;
+import org.jboss.forge.status.common.protocol.conf.ScoresUpdater;
+import org.jboss.forge.status.common.protocol.conf.ServiceConf;
 import org.jboss.forge.status.common.tools.Plugins;
+import org.jboss.forge.status.common.tools.Tools;
 import org.jboss.forge.status.service.impl.db.DBScoresRepositoryManager;
 import org.jboss.forge.status.service.impl.db.protocol.DBScoresFactory;
 
@@ -88,10 +91,11 @@
 	
 	
 	public void init(String portalName, ScoresManager scoresManager,
-						List<PluginConf> pluginsConf, List<String> projectIds)
+						List<PluginConf> pluginsConf, ServiceConf serviceConf,
+						List<String> projectIds)
 													throws ScoresException {
 		
-		log.info("INIT");
+		log.info("ScoresService initialization");
 		
 		this.portalName = portalName;
 		this.scoresManager = scoresManager;
@@ -104,7 +108,11 @@
 			throw new ScoresException("DB service initialization failed." +
 							"\nCause: " + e.getMessage());
 		}
+		
 		scoresFactory = new DBScoresFactory();
+		
+		ScoresUpdater updater = Tools.getScoresUpdater();
+		updater.init(this, serviceConf);
 	}
 	
 	/**

Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/DBScoresFactory.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/DBScoresFactory.java	2006-11-04 17:20:51 UTC (rev 7399)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/DBScoresFactory.java	2006-11-04 18:07:06 UTC (rev 7400)
@@ -23,10 +23,7 @@
 package org.jboss.forge.status.service.impl.db.protocol;
 
 import java.util.List;
-import java.util.Set;
 
-import org.jboss.forge.common.projects.Projects;
-
 import org.jboss.forge.status.common.protocol.conf.PluginValues;
 import org.jboss.forge.status.common.protocol.conf.PluginsValues;
 import org.jboss.forge.status.common.protocol.conf.ScoresFactory;
@@ -38,7 +35,9 @@
 * @author Pawel Wrzeszcz
 */
 public class DBScoresFactory implements ScoresFactory {
-	
+
+	private static final long serialVersionUID = -321472354642673L;
+
 	public PluginsValues createPluginsValues(List<String> projectIds, Plugins plugins) {
 		return new PluginsValuesEntity(projectIds, plugins);
 	}




More information about the jboss-svn-commits mailing list