You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/09/13 18:31:59 UTC
[incubator-pekko-samples] branch main updated: fix pekko property names (#74)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-samples.git
The following commit(s) were added to refs/heads/main by this push:
new 32260d2 fix pekko property names (#74)
32260d2 is described below
commit 32260d2deba4cded33f5c20d841c4f348510f128
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Sep 13 19:31:53 2023 +0100
fix pekko property names (#74)
---
.../src/main/java/sample/cluster/simple/App.java | 2 +-
pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java | 4 ++--
.../src/main/java/sample/cluster/stats/AppOneMaster.java | 4 ++--
.../src/main/java/sample/cluster/transformation/App.java | 4 ++--
4 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/pekko-sample-cluster-java/src/main/java/sample/cluster/simple/App.java b/pekko-sample-cluster-java/src/main/java/sample/cluster/simple/App.java
index 8b37ee4..922b2fe 100644
--- a/pekko-sample-cluster-java/src/main/java/sample/cluster/simple/App.java
+++ b/pekko-sample-cluster-java/src/main/java/sample/cluster/simple/App.java
@@ -35,7 +35,7 @@ public class App {
// Override the configuration of the port
// Override the configuration of the port
Map<String, Object> overrides = new HashMap<>();
- overrides.put("org.apache.pekko.remote.artery.canonical.port", port);
+ overrides.put("pekko.remote.artery.canonical.port", port);
Config config = ConfigFactory.parseMap(overrides)
.withFallback(ConfigFactory.load());
diff --git a/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java b/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java
index 6bbb916..cd30b94 100644
--- a/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java
+++ b/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/App.java
@@ -71,8 +71,8 @@ public class App {
// Override the configuration of the port
Map<String, Object> overrides = new HashMap<>();
- overrides.put("org.apache.pekko.remote.artery.canonical.port", port);
- overrides.put("org.apache.pekko.cluster.roles", Collections.singletonList(role));
+ overrides.put("pekko.remote.artery.canonical.port", port);
+ overrides.put("pekko.cluster.roles", Collections.singletonList(role));
Config config = ConfigFactory.parseMap(overrides)
.withFallback(ConfigFactory.load("stats"));
diff --git a/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/AppOneMaster.java b/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/AppOneMaster.java
index bb5e6fd..77c3a3b 100644
--- a/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/AppOneMaster.java
+++ b/pekko-sample-cluster-java/src/main/java/sample/cluster/stats/AppOneMaster.java
@@ -86,8 +86,8 @@ public class AppOneMaster {
// Override the configuration of the port
Map<String, Object> overrides = new HashMap<>();
- overrides.put("org.apache.pekko.remote.artery.canonical.port", port);
- overrides.put("org.apache.pekko.cluster.roles", Collections.singletonList(role));
+ overrides.put("pekko.remote.artery.canonical.port", port);
+ overrides.put("pekko.cluster.roles", Collections.singletonList(role));
Config config = ConfigFactory.parseMap(overrides)
.withFallback(ConfigFactory.load("stats"));
diff --git a/pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java b/pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java
index 62c27cb..e4537bd 100644
--- a/pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java
+++ b/pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java
@@ -52,8 +52,8 @@ public class App {
// Override the configuration of the port
Map<String, Object> overrides = new HashMap<>();
- overrides.put("org.apache.pekko.remote.artery.canonical.port", port);
- overrides.put("org.apache.pekko.cluster.roles", Collections.singletonList(role));
+ overrides.put("pekko.remote.artery.canonical.port", port);
+ overrides.put("pekko.cluster.roles", Collections.singletonList(role));
Config config = ConfigFactory.parseMap(overrides)
.withFallback(ConfigFactory.load("transformation"));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org