[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@1466382 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/216aa91c Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/216aa91c Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/216aa91c Branch: refs/heads/cellar-2.2.x Commit: 216aa91cb97530638ef7a8d05a01e73c6c4e310a Parents: 94914dd Author: anierbeck <anierbeck@13f79535-47bb-0310-9956-ffa450edef68> Authored: Wed Apr 10 08:34:37 2013 +0000 Committer: anierbeck <anierbeck@13f79535-47bb-0310-9956-ffa450edef68> Committed: Wed Apr 10 08:34:37 2013 +0000 ---------------------------------------------------------------------- .../org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/216aa91c/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java ---------------------------------------------------------------------- diff --git a/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java b/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java index 32a00a8..128d135 100644 --- a/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java +++ b/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java @@ -99,8 +99,10 @@ public class BlobStoreDiscoveryService implements DiscoveryService { LOGGER.debug("CELLAR CLOUD: retrieved a DateTime from blog store"); DateTime registeredTime = (DateTime) obj; if (registeredTime != null && registeredTime.plusSeconds(validityPeriod).isAfterNow()) { + LOGGER.debug("CELLAR CLOUD: adding member {}", ip); members.add(ip); } else { + LOGGER.debug("CELLAR CLOUD: remove container {}", ip); blobStore.removeBlob(container, ip); } } else if (obj instanceof ServiceContainer) { @@ -108,8 +110,10 @@ public class BlobStoreDiscoveryService implements DiscoveryService { ServiceContainer serviceContainer = (ServiceContainer) obj; DateTime registeredTime = serviceContainer.getRegisteredTime(); if (registeredTime != null && registeredTime.plusSeconds(validityPeriod).isAfterNow()) { + LOGGER.debug("CELLAR CLOUD: adding member {} for IP {}", serviceContainer.getHostName(), ip); members.add(serviceContainer.getHostName()); } else { + LOGGER.debug("CELLAR CLOUD: remove container {}", ip); blobStore.removeBlob(container, ip); } }
