Repository: incubator-unomi Updated Branches: refs/heads/feature-UNOMI-70-ES5X 2105da7ec -> adb5fae90
Fix port in cluster configuration Signed-off-by: Serge Huber <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/adb5fae9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/adb5fae9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/adb5fae9 Branch: refs/heads/feature-UNOMI-70-ES5X Commit: adb5fae90660606ed478301b07356b96182540e9 Parents: 2105da7 Author: Serge Huber <[email protected]> Authored: Thu Dec 22 20:42:00 2016 +0100 Committer: Serge Huber <[email protected]> Committed: Thu Dec 22 20:42:00 2016 +0100 ---------------------------------------------------------------------- .../elasticsearch/ElasticSearchPersistenceServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/adb5fae9/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java ---------------------------------------------------------------------- diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java index 8fc7a7e..b3b569c 100644 --- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java +++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java @@ -340,7 +340,7 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, String[] secureEndpointsArray = secureEndpointsPropValue.split(","); Set<String> secureEndpoints = new TreeSet<String>(Arrays.asList(secureEndpointsArray)); publicEndpoints.add(thisKarafNode.getId() + "=" + address + ":" + port); - secureEndpoints.add(thisKarafNode.getId() + "=" + secureAddress + ":" + port); + secureEndpoints.add(thisKarafNode.getId() + "=" + secureAddress + ":" + securePort); karafCellarClusterNodeConfiguration.setProperty(KARAF_CLUSTER_CONFIGURATION_PUBLIC_ENDPOINTS, StringUtils.join(publicEndpoints, ",")); karafCellarClusterNodeConfiguration.setProperty(KARAF_CLUSTER_CONFIGURATION_SECURE_ENDPOINTS, StringUtils.join(secureEndpoints, ",")); configurations.put(KARAF_CELLAR_CLUSTER_NODE_CONFIGURATION, karafCellarClusterNodeConfiguration);
