You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2013/12/18 13:30:16 UTC
[25/50] git commit: [KARAF-2262] - cellar-cloud: The IP is not enough,
sometimes the IP is hidden but a valid dns name is available
[KARAF-2262] - cellar-cloud: The IP is not enough, sometimes the IP is hidden but a valid dns name is available
git-svn-id: https://svn.apache.org/repos/asf/karaf/cellar/branches/cellar-2.2.x@1466371 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/karaf-cellar/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-cellar/commit/94914dd8
Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/94914dd8
Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/94914dd8
Branch: refs/heads/cellar-2.2.x
Commit: 94914dd81ab59777b98114fb09ef4e0a8c332218
Parents: 2b8feb3
Author: anierbeck <an...@13f79535-47bb-0310-9956-ffa450edef68>
Authored: Wed Apr 10 08:12:13 2013 +0000
Committer: anierbeck <an...@13f79535-47bb-0310-9956-ffa450edef68>
Committed: Wed Apr 10 08:12:13 2013 +0000
----------------------------------------------------------------------
.../org/apache/karaf/cellar/core/discovery/DiscoveryTask.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/94914dd8/core/src/main/java/org/apache/karaf/cellar/core/discovery/DiscoveryTask.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/karaf/cellar/core/discovery/DiscoveryTask.java b/core/src/main/java/org/apache/karaf/cellar/core/discovery/DiscoveryTask.java
index a940326..ee2fdd2 100644
--- a/core/src/main/java/org/apache/karaf/cellar/core/discovery/DiscoveryTask.java
+++ b/core/src/main/java/org/apache/karaf/cellar/core/discovery/DiscoveryTask.java
@@ -40,10 +40,12 @@ public class DiscoveryTask implements Runnable {
private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
public void init() {
+ LOGGER.debug("CELLAR DISCOVERY: a new Task initalized");
scheduler.scheduleWithFixedDelay(this, 10, 10, TimeUnit.SECONDS);
}
public void destroy() {
+ LOGGER.debug("CELLAR DISCOVERY: task is beeing destroyed");
scheduler.shutdown();
}
@@ -53,7 +55,6 @@ public class DiscoveryTask implements Runnable {
if (configurationAdmin != null) {
Set<String> members = new LinkedHashSet<String>();
- //TODO: some sort of timing should be included here ...
if (discoveryServices != null && !discoveryServices.isEmpty()) {
for (DiscoveryService service : discoveryServices) {
service.refresh();
@@ -73,7 +74,11 @@ public class DiscoveryTask implements Runnable {
} catch (IOException e) {
LOGGER.error("Failed to update member list", e);
}
+ } else {
+ LOGGER.trace("CELLAR DISCOVERY: no discovery services found ... ");
}
+ } else {
+ LOGGER.trace("CELLAR DISCOVERY: no config admin found");
}
}