svn commit: r1466382 - /karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java

[anierbeck]

Author: anierbeck
Date: Wed Apr 10 08:34:37 2013
New Revision: 1466382

URL: http://svn.apache.org/r1466382
Log:
[KARAF-2262] - cellar-cloud: The IP is not enough, sometimes the IP is hidden 
but a valid dns name is available

Modified:
    
karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java

Modified: 
karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java
URL: 
http://svn.apache.org/viewvc/karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java?rev=1466382&r1=1466381&r2=1466382&view=diff
==============================================================================
--- 
karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java
 (original)
+++ 
karaf/cellar/branches/cellar-2.2.x/cloud/src/main/java/org/apache/karaf/cellar/cloud/BlobStoreDiscoveryService.java
 Wed Apr 10 08:34:37 2013
@@ -99,8 +99,10 @@ public class BlobStoreDiscoveryService i
                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 i
                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);
                 }
             }