|
From: <jbo...@li...> - 2006-06-06 02:03:59
|
Author: wrzep
Date: 2006-06-05 10:26:23 -0400 (Mon, 05 Jun 2006)
New Revision: 4613
Modified:
labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/protocol/ServiceConfImpl.java
labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/tools/ScoresManager.java
Log:
JBLAB-599
next bug fix
Pawel
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/protocol/ServiceConfImpl.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/protocol/ServiceConfImpl.java 2006-06-05 11:29:45 UTC (rev 4612)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/service/impl/protocol/ServiceConfImpl.java 2006-06-05 14:26:23 UTC (rev 4613)
@@ -39,10 +39,10 @@
public ServiceConfImpl(Node serviceNode) {
- properties = parseProperties(serviceNode);
+ properties = remoteService ? parseProperties(serviceNode) : null;
String remoteString = (String) properties.get(Tags.SERVICE_REMOTE_ELEMENT);
- remoteService = remoteString.equals("true");
+ remoteService = remoteString.equals("true");
}
public boolean isRemote() {
Modified: labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/tools/ScoresManager.java
===================================================================
--- labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/tools/ScoresManager.java 2006-06-05 11:29:45 UTC (rev 4612)
+++ labs/jbosslabs/trunk/portal-extensions/forge-status/src/java/org/jboss/forge/status/tools/ScoresManager.java 2006-06-05 14:26:23 UTC (rev 4613)
@@ -59,13 +59,14 @@
public class ScoresManager {
private static Properties properties;
- private Timestamp latestScoresTimestamp;
+ private static boolean remote;
public static void init(String portalName, ServiceConf serviceConf) {
ScoresManagerSync.init(portalName, serviceConf);
properties = serviceConf.getProperties();
+ remote = serviceConf.isRemote();
}
public static void save(Projects projects, List<PluginConf> pluginsConf)
@@ -140,6 +141,8 @@
for(;;) {
+ System.out.println("Trying " + cal.getTime().toString());
+
if (ScoresManagerSync.hasScores(cal)) {
return ScoresManagerSync.getScores(cal);
}
@@ -160,8 +163,14 @@
QueueConnection connection = null;
QueueSession session = null;
QueueSender sender = null;
- Context context = new InitialContext(properties);
+ Context context = null;
+ if (remote) {
+ context = new InitialContext(properties);
+ } else {
+ context = new InitialContext();
+ }
+
queue = (Queue) context.lookup(Constants.QUEUE_NAME);
QueueConnectionFactory factory =
(QueueConnectionFactory) context.lookup("ConnectionFactory");
|