You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by sh...@apache.org on 2017/01/09 16:22:16 UTC
[42/50] [abbrv] incubator-unomi git commit: Fix port in cluster
configuration
Fix port in cluster configuration
Signed-off-by: Serge Huber <sh...@apache.org>
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/master
Commit: adb5fae90660606ed478301b07356b96182540e9
Parents: 2105da7
Author: Serge Huber <sh...@apache.org>
Authored: Thu Dec 22 20:42:00 2016 +0100
Committer: Serge Huber <sh...@apache.org>
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);