commit f8a15e20816fea9e9a6b3a801d96fb26cc63629e
author Jean-Baptiste Onofré <jbonofre@apache.org> Sun Jul 10 21:37:53 2016 +0200
committer Jean-Baptiste Onofré <jbonofre@apache.org> Sun Jul 10 21:37:53 2016 +0200
tree 3c3f099b55511d7a478401d156f15e38841b38d1
parent fee993a8d414c20ba79b72cf3b5007f9e3e37f38

[KARAF-4316] Fix cluster features repository event handling

features/src/main/java/org/apache/karaf/cellar/features/LocalFeaturesListener.java

diff --git a/features/src/main/java/org/apache/karaf/cellar/features/LocalFeaturesListener.java b/features/src/main/java/org/apache/karaf/cellar/features/LocalFeaturesListener.java
index fbf9ad5..a3a104b 100644
--- a/features/src/main/java/org/apache/karaf/cellar/features/LocalFeaturesListener.java
+++ b/features/src/main/java/org/apache/karaf/cellar/features/LocalFeaturesListener.java
@@ -135,6 +135,7 @@
                         clusterRepositoryEvent.setSourceNode(clusterManager.getNode());
                         clusterRepositoryEvent.setInstall(false);
                         clusterRepositoryEvent.setUninstall(false);
+                        clusterRepositoryEvent.setRefresh(false);
                         RepositoryEvent.EventType type = event.getType();
 
                         Map<String, String> clusterRepositories = clusterManager.getMap(Constants.REPOSITORIES_MAP + Configurations.SEPARATOR + group.getName());

features/src/main/java/org/apache/karaf/cellar/features/RepositoryEventHandler.java

diff --git a/features/src/main/java/org/apache/karaf/cellar/features/RepositoryEventHandler.java b/features/src/main/java/org/apache/karaf/cellar/features/RepositoryEventHandler.java
index d974b5b..4f95578 100644
--- a/features/src/main/java/org/apache/karaf/cellar/features/RepositoryEventHandler.java
+++ b/features/src/main/java/org/apache/karaf/cellar/features/RepositoryEventHandler.java
@@ -75,7 +75,7 @@
         try {
             // TODO check if isAllowed
             if (RepositoryEvent.EventType.RepositoryAdded.equals(type)) {
-                if (event.getRefresh()) {
+                if (event.getRefresh() != null && event.getRefresh()) {
                     LOGGER.debug("CELLAR FEATURE: refresh repository {}", uri);
                     featuresService.refreshRepository(new URI(uri));
                 } else {