[jboss-svn-commits] JBL Code SVN: r6872 - in labs/jbosslabs/trunk/portal-extensions/forge-status: . src/java/org/jboss/forge/status/common/protocol src/java/org/jboss/forge/status/common/protocol/conf src/java/org/jboss/forge/status/portlet src/java/org/jboss/forge/status/portlet/conf src/java/org/jboss/forge/status/service/impl src/java/org/jboss/forge/status/service/impl/db/protocol src/web/WEB-INF
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Oct 17 19:07:45 EDT 2006
Author: wrzep
Date: 2006-10-17 19:07:38 -0400 (Tue, 17 Oct 2006)
New Revision: 6872
Added:
labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java
Removed:
labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ServiceScoresManager.java
Modified:
labs/jbosslabs/trunk/portal-extensions/forge-status/project.properties
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/ServiceConf.java
labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/StatusDescriptor.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/ValueEntity.java
labs/jbosslabs/trunk/portal-extensions/forge-status/src/web/WEB-INF/web.xml
Log:
http://jira.jboss.com/jira/browse/JBLAB-781
Pawel
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/project.properties
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/project.properties 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/project.properties 2006-10-17 23:07:38 UTC (rev 6872)
@@ -2,7 +2,7 @@
maven.junit.fork=yes
maven.war.src=${basedir}/src/web
-maven.ejb.includes=**/service/**
+maven.ejb.includes=**/service/**,**/META-INF/**
maven.jar.excludes=**/StatusPortlet.class,**/service/**
maven.war.classes.includes=**/StatusPortlet.class
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-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/ScoresService.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -26,6 +26,8 @@
import java.util.Calendar;
import java.util.List;
+import javax.ejb.Remote;
+
import org.jboss.forge.common.projects.Projects;
import org.jboss.forge.status.common.exceptions.GetScoresException;
import org.jboss.forge.status.common.exceptions.ScoresSaveException;
@@ -36,6 +38,7 @@
/**
* @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
*/
+ at Remote
public interface ScoresService extends Serializable {
public void init(String portalName, ScoresManager scoresManager,
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ServiceConf.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ServiceConf.java 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/common/protocol/conf/ServiceConf.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -22,12 +22,13 @@
package org.jboss.forge.status.common.protocol.conf;
+import java.io.Serializable;
import java.util.Properties;
/**
* @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
*/
-public interface ServiceConf {
+public interface ServiceConf extends Serializable {
public boolean isRemote();
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/StatusDescriptor.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/StatusDescriptor.java 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/StatusDescriptor.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -28,17 +28,16 @@
import org.jboss.forge.common.projects.Projects;
import org.jboss.forge.common.projects.ProjectsHelper;
+
import org.jboss.forge.status.common.Locations;
import org.jboss.forge.status.common.protocol.ScoresManager;
-import org.jboss.forge.status.common.protocol.ScoresRepositoryManager;
import org.jboss.forge.status.common.protocol.conf.PluginConf;
-import org.jboss.forge.status.common.protocol.conf.ScoresFactory;
import org.jboss.forge.status.common.protocol.conf.ServiceConf;
import org.jboss.forge.status.common.tools.Tools;
+
import org.jboss.forge.status.portlet.conf.ServiceConfImpl;
-import org.jboss.forge.status.service.impl.ServiceScoresManager;
-import org.jboss.forge.status.service.impl.db.DBScoresRepositoryManager;
-import org.jboss.forge.status.service.impl.db.protocol.DBScoresFactory;
+import org.jboss.forge.status.portlet.conf.ServiceScoresManager;
+
import org.jboss.logging.Logger;
import org.jboss.portal.common.context.DelegateContext;
@@ -57,9 +56,7 @@
= new HashMap<String,DelegateContext>();
private Map<String,DelegateContext> columnContexts
= new HashMap<String,DelegateContext>();
-
- private ScoresRepositoryManager repositoryManager;
- private ScoresFactory scoresFactory;
+
private ScoresManager scoresManager;
private String portalName;
@@ -97,16 +94,11 @@
List<PluginConf> pluginsConf = Tools.getPluginsConfList(pluginsNode);
Projects projects = ProjectsHelper.getProjects(portalName);
-
- repositoryManager = new DBScoresRepositoryManager();
- scoresFactory = new DBScoresFactory();
-
scoresManager = new ServiceScoresManager(portalName,
serviceConf,
pluginsConf,
- repositoryManager,
- scoresFactory, projects);
+ projects);
} catch (Exception e) {
Added: 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-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/portlet/conf/ServiceScoresManager.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -0,0 +1,303 @@
+/*
+ * 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 java.util.List;
+import java.util.Properties;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+import javax.rmi.PortableRemoteObject;
+
+import org.jboss.forge.common.projects.Projects;
+import org.jboss.forge.status.common.Constants;
+import org.jboss.forge.status.common.exceptions.GetScoresException;
+import org.jboss.forge.status.common.exceptions.ScoresException;
+import org.jboss.forge.status.common.exceptions.ScoresSaveException;
+import org.jboss.forge.status.common.protocol.ScoresManager;
+import org.jboss.forge.status.common.protocol.ScoresRepositoryManager;
+import org.jboss.forge.status.common.protocol.ScoresService;
+import org.jboss.forge.status.common.protocol.ScoresServiceLocal;
+import org.jboss.forge.status.common.protocol.ScoresServiceRemote;
+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.ScoresFactory;
+import org.jboss.forge.status.common.protocol.conf.ServiceConf;
+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;
+
+import org.jboss.logging.Logger;
+
+/**
+* @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
+*/
+
+public class ServiceScoresManager implements ScoresManager {
+
+ private static final long serialVersionUID = -3398452363516977124L;
+
+ private Properties properties;
+ private boolean isRemote;
+ private boolean asyncSave = false;
+ private Logger log;
+
+ private ScoresService service;
+
+ public ServiceScoresManager(String portalName,
+ ServiceConf serviceConf,
+ List<PluginConf> pluginsConf,
+ Projects projects)
+ throws ScoresException {
+
+ properties = serviceConf.getProperties();
+ isRemote = serviceConf.isRemote();
+
+ log = Logger.getLogger(this.getClass());
+
+ try {
+ ScoresRepositoryManager repositoryManager =
+ new DBScoresRepositoryManager();
+ ScoresFactory scoresFactory = new DBScoresFactory();
+
+ service = getService();
+ service.init(portalName, this, repositoryManager, scoresFactory,
+ pluginsConf, projects);
+ } catch (NamingException e) {
+ throw new ScoresException(e);
+ }
+
+ sheduleUpdates(serviceConf);
+ }
+
+ public void saveAsync(final Projects projects,
+ final List<PluginConf> pluginsConf) {
+
+ new Thread() {
+
+ public void run() {
+ saveAsyncOnce(projects, pluginsConf);
+ }
+
+ }.start();
+
+ }
+
+ private synchronized void saveAsyncOnce(Projects projects,
+ List<PluginConf> pluginsConf) {
+ if (asyncSave) {
+ return;
+ }
+
+ try {
+ log.info("Saving scores asynchronously...");
+ save();
+ asyncSave = true;
+ log.info("Finished async save.");
+ } catch (ScoresSaveException e) {
+ log.warn("Async saving scores failed.", e);
+ }
+ }
+
+ public synchronized void save() throws ScoresSaveException {
+
+ service.save();
+ }
+
+
+ public boolean hasScores(Calendar cal) throws NamingException {
+
+ return service.hasPluginsValues(cal);
+ }
+
+
+ public PluginsValues getScores(Calendar cal)
+ throws GetScoresException {
+
+ PluginsValues pluginsValues = null;
+
+ try {
+ pluginsValues = service.getPluginsValues(cal);
+ } catch (Exception e) {
+ throw new GetScoresException(e);
+ }
+
+ if (pluginsValues == null) {
+ throw new GetScoresException();
+ }
+
+ return pluginsValues;
+ }
+
+
+ public PluginsValues getLatestScores()
+ throws GetScoresException {
+
+ Calendar cal = Calendar.getInstance();
+ Tools.truncate(cal);
+ int attempts = 0;
+
+ for(;;) {
+
+ log.debug("Trying " + cal.getTime().toString());
+
+ boolean hasScores;
+
+ try {
+ hasScores = hasScores(cal);
+ } catch (NamingException e) {
+ throw new GetScoresException(e);
+ }
+
+ if (hasScores) {
+ return getScores(cal);
+ }
+
+ if ((++attempts) == Constants.MAX_ATTEMPTS) {
+ throw new GetScoresException(
+ "Can not find any recently saved scores. " +
+ "Gave up after " + attempts + " attempts.");
+ }
+
+ cal.add(Calendar.DAY_OF_MONTH, -1);
+ }
+ }
+
+
+ /**
+ * For the specified plugin returns historical project score
+ * from the given <code>date</code> in the past.
+ *
+ * Notice that only year, month and day matter in passed dates.
+ *
+ * @return project score from the given date for specified plugin
+ * @throws GetScoresException
+ */
+ public long getValue(String pluginId, String projectId,
+ Calendar cal)
+ throws GetScoresException {
+
+ return service.getValue(pluginId, projectId, cal);
+ }
+
+ /**
+ * For the given plugin and project ids returns stored value.
+ *
+ * @param pluginId plugin id
+ * @param projectId project id
+ * @return stored plugin value for specified project
+ * @throws GetScoresException
+ * Thrown when requested value was not found
+ */
+ public long getValue(String pluginId, String projectId,
+ Calendar start, Calendar end) throws GetScoresException {
+
+ return service.getValue(pluginId, projectId, start, end);
+ }
+
+ private ScoresService getService() throws NamingException {
+ /*
+ String url = "http://localhost:8080/jmm-service";
+
+ HessianProxyFactory factory = new HessianProxyFactory();
+ ScoresService service;
+ try {
+ service = (ScoresService) factory.create(ScoresService.class, url);
+ } catch (MalformedURLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ return null;
+ }
+
+ return service;
+ */
+
+ log.info("isRemote: " + isRemote);
+ log.info("properties:" + properties);
+
+ Context context = null;
+ if (isRemote) {
+ context = new InitialContext(properties);
+ } else {
+ context = new InitialContext();
+ }
+
+ // Perform look up using JNDI name of ejb object
+ String serviceBinding = Constants.STATUS_REMOTE_SERVICE;
+ /* (isRemote ? Constants.STATUS_REMOTE_SERVICE :
+ Constants.STATUS_LOCAL_SERVICE);*/
+
+ Object ref = context.lookup(serviceBinding);
+
+ // Narrow the reference of the object returned by lookup() method
+ ScoresService service =
+ (ScoresService) PortableRemoteObject.narrow( ref, ScoresService.class);
+ // (isRemote ? ScoresServiceRemote.class :
+ // ScoresServiceLocal.class));
+
+ return service;
+
+ }
+
+ private void sheduleUpdates(ServiceConf conf) {
+
+ ScoresUpdater updater = getScoresUpdater();
+
+ if (updater != null) {
+
+ updater.init(this, conf);
+ }
+ }
+
+ 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;
+ }
+
+}
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-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ScoresServiceImpl.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -29,7 +29,6 @@
import javax.ejb.Remote;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
-
import org.jboss.annotation.ejb.LocalBinding;
import org.jboss.annotation.ejb.RemoteBinding;
import org.jboss.annotation.ejb.Service;
@@ -55,9 +54,9 @@
*/
@Service
- at Local(ScoresServiceLocal.class)
- at LocalBinding(jndiBinding=Constants.STATUS_LOCAL_SERVICE)
- at Remote(ScoresServiceRemote.class)
+//@Local(ScoresServiceLocal.class)
+//@LocalBinding(jndiBinding=Constants.STATUS_LOCAL_SERVICE)
+ at Remote(ScoresService.class)
@RemoteBinding(jndiBinding=Constants.STATUS_REMOTE_SERVICE)
public class ScoresServiceImpl implements ScoresService {
Deleted: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ServiceScoresManager.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ServiceScoresManager.java 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/ServiceScoresManager.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -1,280 +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.service.impl;
-
-import java.util.Calendar;
-import java.util.List;
-import java.util.Properties;
-
-import javax.naming.Context;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-
-import javax.rmi.PortableRemoteObject;
-
-import org.jboss.forge.common.projects.Projects;
-import org.jboss.forge.status.common.Constants;
-import org.jboss.forge.status.common.exceptions.GetScoresException;
-import org.jboss.forge.status.common.exceptions.ScoresException;
-import org.jboss.forge.status.common.exceptions.ScoresSaveException;
-import org.jboss.forge.status.common.protocol.ScoresManager;
-import org.jboss.forge.status.common.protocol.ScoresRepositoryManager;
-import org.jboss.forge.status.common.protocol.ScoresService;
-import org.jboss.forge.status.common.protocol.ScoresServiceLocal;
-import org.jboss.forge.status.common.protocol.ScoresServiceRemote;
-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.ScoresFactory;
-import org.jboss.forge.status.common.protocol.conf.ServiceConf;
-import org.jboss.forge.status.common.tools.Tools;
-
-import org.jboss.logging.Logger;
-
-/**
-* @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
-*/
-
-public class ServiceScoresManager implements ScoresManager {
-
- private static final long serialVersionUID = -3398452363516977124L;
-
- private Properties properties;
- private boolean isRemote;
- private boolean asyncSave = false;
- private Logger log;
-
- private ScoresService service;
-
- public ServiceScoresManager(String portalName,
- ServiceConf serviceConf,
- List<PluginConf> pluginsConf,
- ScoresRepositoryManager repositoryManager,
- ScoresFactory scoresFactory,
- Projects projects)
- throws ScoresException {
-
- properties = serviceConf.getProperties();
- isRemote = serviceConf.isRemote();
-
- log = Logger.getLogger(this.getClass());
-
- try {
- service = getService();
- service.init(portalName, this, repositoryManager, scoresFactory,
- pluginsConf, projects);
- } catch (NamingException e) {
- throw new ScoresException(e);
- }
-
- sheduleUpdates(serviceConf);
- }
-
- public void saveAsync(final Projects projects,
- final List<PluginConf> pluginsConf) {
-
- new Thread() {
-
- public void run() {
- saveAsyncOnce(projects, pluginsConf);
- }
-
- }.start();
-
- }
-
- private synchronized void saveAsyncOnce(Projects projects,
- List<PluginConf> pluginsConf) {
- if (asyncSave) {
- return;
- }
-
- try {
- log.info("Saving scores asynchronously...");
- save();
- asyncSave = true;
- log.info("Finished async save.");
- } catch (ScoresSaveException e) {
- log.warn("Async saving scores failed.", e);
- }
- }
-
- public synchronized void save() throws ScoresSaveException {
-
- service.save();
- }
-
-
- public boolean hasScores(Calendar cal) throws NamingException {
-
- return service.hasPluginsValues(cal);
- }
-
-
- public PluginsValues getScores(Calendar cal)
- throws GetScoresException {
-
- PluginsValues pluginsValues = null;
-
- try {
- pluginsValues = service.getPluginsValues(cal);
- } catch (Exception e) {
- throw new GetScoresException(e);
- }
-
- if (pluginsValues == null) {
- throw new GetScoresException();
- }
-
- return pluginsValues;
- }
-
-
- public PluginsValues getLatestScores()
- throws GetScoresException {
-
- Calendar cal = Calendar.getInstance();
- Tools.truncate(cal);
- int attempts = 0;
-
- for(;;) {
-
- log.debug("Trying " + cal.getTime().toString());
-
- boolean hasScores;
-
- try {
- hasScores = hasScores(cal);
- } catch (NamingException e) {
- throw new GetScoresException(e);
- }
-
- if (hasScores) {
- return getScores(cal);
- }
-
- if ((++attempts) == Constants.MAX_ATTEMPTS) {
- throw new GetScoresException(
- "Can not find any recently saved scores. " +
- "Gave up after " + attempts + " attempts.");
- }
-
- cal.add(Calendar.DAY_OF_MONTH, -1);
- }
- }
-
-
- /**
- * For the specified plugin returns historical project score
- * from the given <code>date</code> in the past.
- *
- * Notice that only year, month and day matter in passed dates.
- *
- * @return project score from the given date for specified plugin
- * @throws GetScoresException
- */
- public long getValue(String pluginId, String projectId,
- Calendar cal)
- throws GetScoresException {
-
- return service.getValue(pluginId, projectId, cal);
- }
-
- /**
- * For the given plugin and project ids returns stored value.
- *
- * @param pluginId plugin id
- * @param projectId project id
- * @return stored plugin value for specified project
- * @throws GetScoresException
- * Thrown when requested value was not found
- */
- public long getValue(String pluginId, String projectId,
- Calendar start, Calendar end) throws GetScoresException {
-
- return service.getValue(pluginId, projectId, start, end);
- }
-
- private ScoresService getService() throws NamingException {
-
- Context context = null;
- if (isRemote) {
- context = new InitialContext(properties);
- } else {
- context = new InitialContext();
- }
-
- // Perform look up using JNDI name of ejb object
- String serviceBinding =
- (isRemote ? Constants.STATUS_REMOTE_SERVICE :
- Constants.STATUS_LOCAL_SERVICE);
-
- Object ref = context.lookup(serviceBinding);
-
- // Narrow the reference of the object returned by lookup() method
- ScoresService service =
- (ScoresService) PortableRemoteObject.narrow( ref,
- (isRemote ? ScoresServiceRemote.class :
- ScoresServiceLocal.class));
-
- return service;
- }
-
- private void sheduleUpdates(ServiceConf conf) {
-
- ScoresUpdater updater = getScoresUpdater();
-
- if (updater != null) {
-
- updater.init(this, conf);
- }
- }
-
- 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;
- }
-
-}
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/ValueEntity.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/ValueEntity.java 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/db/protocol/ValueEntity.java 2006-10-17 23:07:38 UTC (rev 6872)
@@ -33,6 +33,7 @@
import javax.persistence.Table;
+
/**
* @author Pawel Wrzeszcz (pawel.wrzeszcz [at] gmail.com)
*/
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/web/WEB-INF/web.xml
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/web/WEB-INF/web.xml 2006-10-17 21:23:30 UTC (rev 6871)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/web/WEB-INF/web.xml 2006-10-17 23:07:38 UTC (rev 6872)
@@ -13,4 +13,23 @@
<url-pattern>/repo-access/*</url-pattern>
<dispatcher>INCLUDE</dispatcher>
</filter-mapping>
+ <!--
+ <servlet>
+ <servlet-name>jmm-service</servlet-name>
+ <servlet-class>com.caucho.hessian.server.HessianServlet</servlet-class>
+ <init-param>
+ <param-name>home-class</param-name>
+ <param-value>org.jboss.forge.status.service.impl.ScoresServiceImpl</param-value>
+ </init-param>
+ <init-param>
+ <param-name>home-api</param-name>
+ <param-value>org.jboss.forge.status.common.protocol.ScoresService</param-value>
+ </init-param>
+ </servlet>
+
+ <servlet-mapping>
+ <url-pattern>/jmm-service</url-pattern>
+ <servlet-name>jmm-service</servlet-name>
+ </servlet-mapping>
+-->
</web-app>
\ No newline at end of file
More information about the jboss-svn-commits
mailing list