You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2023/03/08 21:00:08 UTC
[incubator-pekko] branch main updated (defddc6af5 -> 904705b3df)
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
from defddc6af5 acknowledge use of scala-collection-compat code (#236)
new 785369030d change default port number to 7355
new 1969f7580d change 2552+ port numbers
new c23f9fb834 artery port = 17355
new 5322174ecc replace 2551 with 7354
new 904705b3df Update migration-guides.md
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/pekko/actor/ActorPathSpec.scala | 26 +++++------
.../pekko/actor/LocalActorRefProviderSpec.scala | 2 +-
.../apache/pekko/actor/RelativeActorPathSpec.scala | 2 +-
.../pekko/cluster/ddata/ORSetMergeBenchmark.scala | 2 +-
.../cluster/ddata/VersionVectorBenchmark.scala | 2 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 8 ++--
.../apache/pekko/cluster/metrics/MetricSpec.scala | 32 +++++++-------
.../cluster/metrics/WeightedRouteesSpec.scala | 8 ++--
.../metrics/protobuf/MessageSerializerSpec.scala | 12 +++---
.../ExternalShardAllocationCompileOnlyTest.java | 2 +-
.../ExternalShardAllocationCompileOnlySpec.scala | 2 +-
.../ClusterShardingMessageSerializerSpec.scala | 6 +--
.../pekko/cluster/client/ClusterClientSpec.scala | 4 +-
.../pekko/cluster/client/ClusterClientTest.java | 4 +-
.../ClusterClientMessageSerializerSpec.scala | 6 +--
.../cluster/typed/BasicClusterExampleTest.java | 6 +--
.../cluster/typed/BasicClusterExampleSpec.scala | 10 ++---
cluster/jmx-client/pekko-cluster | 8 ++--
.../org/apache/pekko/cluster/ClusterJmx.scala | 22 +++++-----
.../cluster/ClusterDomainEventPublisherSpec.scala | 12 +++---
.../pekko/cluster/ClusterDomainEventSpec.scala | 50 +++++++++++-----------
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 12 +++---
.../org/apache/pekko/cluster/ClusterSpec.scala | 8 ++--
.../org/apache/pekko/cluster/GossipSpec.scala | 22 +++++-----
.../pekko/cluster/GossipTargetSelectorSpec.scala | 16 +++----
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 2 +-
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 12 +++---
.../apache/pekko/cluster/MembershipStateSpec.scala | 30 ++++++-------
.../pekko/cluster/ReachabilityPerfSpec.scala | 4 +-
.../apache/pekko/cluster/ReachabilitySpec.scala | 10 ++---
.../protobuf/ClusterMessageSerializerSpec.scala | 12 +++---
.../apache/pekko/cluster/sbr/TestAddresses.scala | 2 +-
.../pekko/cluster/testkit/AutoDownSpec.scala | 6 +--
.../protobuf/ReplicatorMessageSerializer.scala | 2 +-
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 8 ++--
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 6 +--
.../apache/pekko/cluster/ddata/LWWMapSpec.scala | 4 +-
.../pekko/cluster/ddata/LWWRegisterSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 6 +--
.../org/apache/pekko/cluster/ddata/ORMapSpec.scala | 4 +-
.../pekko/cluster/ddata/ORMultiMapSpec.scala | 4 +-
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 8 ++--
.../pekko/cluster/ddata/PNCounterMapSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/PNCounterSpec.scala | 4 +-
.../pekko/cluster/ddata/PruningStateSpec.scala | 8 ++--
.../pekko/cluster/ddata/VersionVectorSpec.scala | 8 ++--
.../pekko/cluster/ddata/WriteAggregatorSpec.scala | 8 ++--
docs/src/main/paradox/cluster-usage.md | 2 +-
docs/src/main/paradox/project/migration-guides.md | 10 +++--
docs/src/main/paradox/remoting-artery.md | 8 ++--
docs/src/main/paradox/remoting.md | 12 +++---
docs/src/main/paradox/typed/cluster.md | 8 ++--
.../jdocs/cluster/StatsSampleOneMasterMain.java | 2 +-
.../LambdaPersistencePluginDocTest.java | 2 +-
.../src/test/scala/docs/config/ConfigDocSpec.scala | 2 +-
.../persistence/PersistencePluginDocSpec.scala | 2 +-
.../test/scala/docs/routing/RouterDocSpec.scala | 16 +++----
remote/src/main/resources/reference.conf | 28 ++++++------
.../remote/RemoteConsistentHashingRouterSpec.scala | 10 ++---
.../apache/pekko/remote/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeathWatchSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/classic/ActorsLeakSpec.scala | 2 +-
.../remote/classic/RemoteDeathWatchSpec.scala | 4 +-
.../jackson/JacksonSerializerSpec.scala | 4 +-
65 files changed, 284 insertions(+), 280 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko] 02/05: change 2552+ port numbers
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit 1969f7580dcb30f1db7d5019f3eee2a54e596a88
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Mon Mar 6 12:29:03 2023 +0100
change 2552+ port numbers
---
.../apache/pekko/cluster/metrics/MetricSpec.scala | 32 +++++++++++-----------
.../org/apache/pekko/cluster/ClusterSpec.scala | 4 +--
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 4 +--
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 2 +-
.../pekko/cluster/ddata/PruningStateSpec.scala | 4 +--
.../pekko/cluster/ddata/VersionVectorSpec.scala | 4 +--
docs/src/main/paradox/remoting.md | 4 +--
.../src/test/scala/docs/config/ConfigDocSpec.scala | 2 +-
remote/src/main/resources/reference.conf | 8 +++---
.../pekko/remote/classic/ActorsLeakSpec.scala | 2 +-
11 files changed, 34 insertions(+), 34 deletions(-)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricSpec.scala
index eecb2274a4..d6a03c2cec 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricSpec.scala
@@ -69,8 +69,8 @@ class MetricNumericConverterSpec extends AnyWordSpec with Matchers with MetricNu
@nowarn
class NodeMetricsSpec extends AnyWordSpec with Matchers {
- val node1 = Address("pekko", "sys", "a", 2554)
- val node2 = Address("pekko", "sys", "a", 2555)
+ val node1 = Address("pekko", "sys", "a", 7357)
+ val node2 = Address("pekko", "sys", "a", 7358)
"NodeMetrics must" must {
@@ -162,8 +162,8 @@ class MetricsGossipSpec
"A MetricsGossip" must {
"add new NodeMetrics" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
- val m2 = NodeMetrics(Address("pekko", "sys", "a", 2555), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
+ val m2 = NodeMetrics(Address("pekko", "sys", "a", 7358), newTimestamp, collector.sample().metrics)
m1.metrics.size should be > 3
m2.metrics.size should be > 3
@@ -179,8 +179,8 @@ class MetricsGossipSpec
}
"merge peer metrics" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
- val m2 = NodeMetrics(Address("pekko", "sys", "a", 2555), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
+ val m2 = NodeMetrics(Address("pekko", "sys", "a", 7358), newTimestamp, collector.sample().metrics)
val g1 = MetricsGossip.empty :+ m1 :+ m2
g1.nodes.size should ===(2)
@@ -194,9 +194,9 @@ class MetricsGossipSpec
}
"merge an existing metric set for a node and update node ring" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
- val m2 = NodeMetrics(Address("pekko", "sys", "a", 2555), newTimestamp, collector.sample().metrics)
- val m3 = NodeMetrics(Address("pekko", "sys", "a", 2556), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
+ val m2 = NodeMetrics(Address("pekko", "sys", "a", 7358), newTimestamp, collector.sample().metrics)
+ val m3 = NodeMetrics(Address("pekko", "sys", "a", 7359), newTimestamp, collector.sample().metrics)
val m2Updated = m2.copy(metrics = newSample(m2.metrics), timestamp = m2.timestamp + 1000)
val g1 = MetricsGossip.empty :+ m1 :+ m2
@@ -215,14 +215,14 @@ class MetricsGossipSpec
}
"get the current NodeMetrics if it exists in the local nodes" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
val g1 = MetricsGossip.empty :+ m1
g1.nodeMetricsFor(m1.address).map(_.metrics) should ===(Some(m1.metrics))
}
"remove a node if it is no longer Up" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
- val m2 = NodeMetrics(Address("pekko", "sys", "a", 2555), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
+ val m2 = NodeMetrics(Address("pekko", "sys", "a", 7358), newTimestamp, collector.sample().metrics)
val g1 = MetricsGossip.empty :+ m1 :+ m2
g1.nodes.size should ===(2)
@@ -234,8 +234,8 @@ class MetricsGossipSpec
}
"filter nodes" in {
- val m1 = NodeMetrics(Address("pekko", "sys", "a", 2554), newTimestamp, collector.sample().metrics)
- val m2 = NodeMetrics(Address("pekko", "sys", "a", 2555), newTimestamp, collector.sample().metrics)
+ val m1 = NodeMetrics(Address("pekko", "sys", "a", 7357), newTimestamp, collector.sample().metrics)
+ val m2 = NodeMetrics(Address("pekko", "sys", "a", 7358), newTimestamp, collector.sample().metrics)
val g1 = MetricsGossip.empty :+ m1 :+ m2
g1.nodes.size should ===(2)
@@ -254,8 +254,8 @@ class MetricValuesSpec extends PekkoSpec(MetricsConfig.defaultEnabled) with Metr
val collector = createMetricsCollector
- val node1 = NodeMetrics(Address("pekko", "sys", "a", 2554), 1, collector.sample().metrics)
- val node2 = NodeMetrics(Address("pekko", "sys", "a", 2555), 1, collector.sample().metrics)
+ val node1 = NodeMetrics(Address("pekko", "sys", "a", 7357), 1, collector.sample().metrics)
+ val node2 = NodeMetrics(Address("pekko", "sys", "a", 7358), 1, collector.sample().metrics)
val nodes: Seq[NodeMetrics] = {
(1 to 100).foldLeft(List(node1, node2)) { (nodes, _) =>
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
index 7de9e559a9..4a2c87e246 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
@@ -358,7 +358,7 @@ class ClusterSpec extends PekkoSpec(ClusterSpec.config) with ImplicitSender {
""").withFallback(ConfigFactory.parseString(ClusterSpec.config))
val sys1 = ActorSystem("ClusterSpec4", getConfig(7355))
- val sys2 = ActorSystem("ClusterSpec4", getConfig(2553))
+ val sys2 = ActorSystem("ClusterSpec4", getConfig(7356))
try {
Cluster(sys1)
@@ -369,7 +369,7 @@ class ClusterSpec extends PekkoSpec(ClusterSpec.config) with ImplicitSender {
info1.getAttributes.length should be > 0
info1.getOperations.length should be > 0
- val name2 = new ObjectName(s"pekko:type=Cluster,port=2553")
+ val name2 = new ObjectName(s"pekko:type=Cluster,port=7356")
val info2 = ManagementFactory.getPlatformMBeanServer.getMBeanInfo(name2)
info2.getAttributes.length should be > 0
info2.getOperations.length should be > 0
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
index d25f8adbde..c48c080db8 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
@@ -26,8 +26,8 @@ class DataEnvelopeSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
- val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
- val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
+ val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
+ val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
val obsoleteTimeInFuture = System.currentTimeMillis() + 3600 * 1000
val oldObsoleteTime = System.currentTimeMillis() - 3600 * 1000
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
index 2d7c90cfed..d04649f707 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class GCounterSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
- val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
+ val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
"A GCounter" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
index 4d92b37107..f8a1cee29d 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
@@ -27,7 +27,7 @@ class ORSetSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
- val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
+ val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val nodeA = UniqueAddress(Address("pekko", "Sys", "a", 7355), 1L)
val nodeB = UniqueAddress(nodeA.address.copy(host = Some("b")), 2L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
index ef681c8dc0..24ab7c978b 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
@@ -25,8 +25,8 @@ class PruningStateSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
- val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
- val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
+ val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
+ val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
"Pruning state" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
index 6be8df509f..ff65f934b4 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
@@ -31,8 +31,8 @@ class VersionVectorSpec
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
- val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
- val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
+ val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
+ val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
override def afterAll(): Unit = {
shutdown()
diff --git a/docs/src/main/paradox/remoting.md b/docs/src/main/paradox/remoting.md
index edee72d236..2d02e8cb40 100644
--- a/docs/src/main/paradox/remoting.md
+++ b/docs/src/main/paradox/remoting.md
@@ -190,7 +190,7 @@ pekko {
actor {
deployment {
/sampleActor {
- remote = "pekko.tcp://sampleActorSystem@127.0.0.1:2553"
+ remote = "pekko.tcp://sampleActorSystem@127.0.0.1:7356"
}
}
}
@@ -200,7 +200,7 @@ pekko {
The configuration above instructs Pekko to react when an actor with path `/sampleActor` is created, i.e.
using @scala[`system.actorOf(Props(...), "sampleActor")`]@java[`system.actorOf(new Props(...), "sampleActor")`]. This specific actor will not be directly instantiated,
but instead the remote daemon of the remote system will be asked to create the actor,
-which in this sample corresponds to `sampleActorSystem@127.0.0.1:2553`.
+which in this sample corresponds to `sampleActorSystem@127.0.0.1:7356`.
Once you have configured the properties above you would do the following in code:
diff --git a/docs/src/test/scala/docs/config/ConfigDocSpec.scala b/docs/src/test/scala/docs/config/ConfigDocSpec.scala
index 63edabdc4a..dacdaf9f87 100644
--- a/docs/src/test/scala/docs/config/ConfigDocSpec.scala
+++ b/docs/src/test/scala/docs/config/ConfigDocSpec.scala
@@ -78,7 +78,7 @@ class ConfigDocSpec extends AnyWordSpec with Matchers {
# '/user/actorA/actorB' is a remote deployed actor
/actorA/actorB {
- remote = "pekko://sampleActorSystem@127.0.0.1:2553"
+ remote = "pekko://sampleActorSystem@127.0.0.1:7356"
}
# all direct children of '/user/actorC' have a dedicated dispatcher
diff --git a/remote/src/main/resources/reference.conf b/remote/src/main/resources/reference.conf
index 8e761ffa13..4f03796b62 100644
--- a/remote/src/main/resources/reference.conf
+++ b/remote/src/main/resources/reference.conf
@@ -513,8 +513,8 @@ pekko {
# Use 0 if you want a random available port. Examples:
#
# pekko.remote.classic.netty.tcp.port = 7355
- # pekko.remote.classic.netty.tcp.bind-port = 2553
- # Network interface will be bound to the 2553 port, but remoting protocol will
+ # pekko.remote.classic.netty.tcp.bind-port = 7356
+ # Network interface will be bound to the 7356 port, but remoting protocol will
# expect messages sent to port 7355.
#
# pekko.remote.classic.netty.tcp.port = 0
@@ -528,8 +528,8 @@ pekko {
# expect messages sent to port 7355.
#
# pekko.remote.classic.netty.tcp.port = 0
- # pekko.remote.classic.netty.tcp.bind-port = 2553
- # Network interface will be bound to the 2553 port, and remoting protocol will
+ # pekko.remote.classic.netty.tcp.bind-port = 7356
+ # Network interface will be bound to the 7356 port, and remoting protocol will
# expect messages sent to the bound port.
#
# pekko.remote.classic.netty.tcp.port = 7355
diff --git a/remote/src/test/scala/org/apache/pekko/remote/classic/ActorsLeakSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/classic/ActorsLeakSpec.scala
index d5db97ce2c..9d3c2d67b6 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/classic/ActorsLeakSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/classic/ActorsLeakSpec.scala
@@ -124,7 +124,7 @@ class ActorsLeakSpec extends PekkoSpec(ActorsLeakSpec.config) with ImplicitSende
"remote",
ConfigFactory.parseString("""
pekko.remote.artery.enabled = false
- pekko.remote.classic.netty.tcp.port = 2553
+ pekko.remote.classic.netty.tcp.port = 7356
""".stripMargin).withFallback(config))
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko] 05/05: Update migration-guides.md
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit 904705b3dfc28f8ecc0bef3e4e7f7ff8dc26c589
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Mar 8 13:07:44 2023 +0100
Update migration-guides.md
---
docs/src/main/paradox/project/migration-guides.md | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
diff --git a/docs/src/main/paradox/project/migration-guides.md b/docs/src/main/paradox/project/migration-guides.md
index 029ad79415..59164f9a4d 100644
--- a/docs/src/main/paradox/project/migration-guides.md
+++ b/docs/src/main/paradox/project/migration-guides.md
@@ -16,11 +16,15 @@ This is just stub documentation. It will be improved.
* Pekko packages start with "org.apache.pekko" instead of "akka" - e.g. `import org.apache.pekko.actor` instead of `import akka.actor`
* Where class names have "Akka" in the name, the Pekko ones have "Pekko" - e.g. PekkoException instead of AkkaException
* Configs in `application.conf` use "pekko" prefix instead of "akka"
+* We have changed the default ports used by the pekko-remote module.
+* With @ref:[Classic Remoting](../remoting.md), Akka defaults to 2552, while Pekko defaults to 7355.
+* With @ref:[Artery Remoting](../remoting-artery.md), Akka defaults to 25520, while Pekko defaults to 17355.
We are still investigating the effects of how the package name changes affect the @ref:[Persistence](../persistence.md)
and @ref:[Cluster](../cluster-usage.md) modules.
-Data persisted with "akka-persistence" may not yet be usable with "pekko-persistence" (or vice versa).
-Akka and Pekko nodes may not be able to form a cluster or messages may not be recognised if passed between nodes
-of different types.
+
+It appears that data persisted with "akka-persistence" is usable with "pekko-persistence" (and vice versa).
+
+We currently do not expect that Akka and Pekko nodes will be able to form a cluster.
We may be able to provide [Scalafix](https://scalacenter.github.io/scalafix/) scripts to help with migrations.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko] 01/05: change default port number to 7355
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit 785369030d52514e11fca098d537db9e97d112f1
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Mon Mar 6 12:19:29 2023 +0100
change default port number to 7355
---
.../org/apache/pekko/actor/ActorPathSpec.scala | 26 +++++------
.../pekko/actor/LocalActorRefProviderSpec.scala | 2 +-
.../apache/pekko/actor/RelativeActorPathSpec.scala | 2 +-
.../pekko/cluster/ddata/ORSetMergeBenchmark.scala | 2 +-
.../cluster/ddata/VersionVectorBenchmark.scala | 2 +-
.../metrics/protobuf/MessageSerializerSpec.scala | 12 +++---
.../ExternalShardAllocationCompileOnlyTest.java | 2 +-
.../ExternalShardAllocationCompileOnlySpec.scala | 2 +-
.../ClusterShardingMessageSerializerSpec.scala | 6 +--
.../pekko/cluster/client/ClusterClientSpec.scala | 4 +-
.../pekko/cluster/client/ClusterClientTest.java | 4 +-
.../ClusterClientMessageSerializerSpec.scala | 6 +--
.../cluster/typed/BasicClusterExampleTest.java | 2 +-
.../cluster/typed/BasicClusterExampleSpec.scala | 4 +-
cluster/jmx-client/pekko-cluster | 4 +-
.../org/apache/pekko/cluster/ClusterJmx.scala | 22 +++++-----
.../cluster/ClusterDomainEventPublisherSpec.scala | 10 ++---
.../pekko/cluster/ClusterDomainEventSpec.scala | 50 +++++++++++-----------
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 12 +++---
.../org/apache/pekko/cluster/ClusterSpec.scala | 4 +-
.../org/apache/pekko/cluster/GossipSpec.scala | 22 +++++-----
.../pekko/cluster/GossipTargetSelectorSpec.scala | 16 +++----
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 2 +-
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 12 +++---
.../apache/pekko/cluster/MembershipStateSpec.scala | 30 ++++++-------
.../pekko/cluster/ReachabilityPerfSpec.scala | 4 +-
.../apache/pekko/cluster/ReachabilitySpec.scala | 10 ++---
.../protobuf/ClusterMessageSerializerSpec.scala | 12 +++---
.../apache/pekko/cluster/sbr/TestAddresses.scala | 2 +-
.../pekko/cluster/testkit/AutoDownSpec.scala | 6 +--
.../protobuf/ReplicatorMessageSerializer.scala | 2 +-
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 2 +-
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 2 +-
.../apache/pekko/cluster/ddata/LWWMapSpec.scala | 2 +-
.../pekko/cluster/ddata/LWWRegisterSpec.scala | 2 +-
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 4 +-
.../org/apache/pekko/cluster/ddata/ORMapSpec.scala | 2 +-
.../pekko/cluster/ddata/ORMultiMapSpec.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 4 +-
.../pekko/cluster/ddata/PNCounterMapSpec.scala | 2 +-
.../apache/pekko/cluster/ddata/PNCounterSpec.scala | 2 +-
.../pekko/cluster/ddata/PruningStateSpec.scala | 2 +-
.../pekko/cluster/ddata/VersionVectorSpec.scala | 2 +-
.../pekko/cluster/ddata/WriteAggregatorSpec.scala | 8 ++--
docs/src/main/paradox/cluster-usage.md | 2 +-
docs/src/main/paradox/remoting-artery.md | 8 ++--
docs/src/main/paradox/remoting.md | 8 ++--
docs/src/main/paradox/typed/cluster.md | 8 ++--
.../jdocs/cluster/StatsSampleOneMasterMain.java | 2 +-
.../LambdaPersistencePluginDocTest.java | 2 +-
.../persistence/PersistencePluginDocSpec.scala | 2 +-
.../test/scala/docs/routing/RouterDocSpec.scala | 16 +++----
remote/src/main/resources/reference.conf | 20 ++++-----
.../remote/RemoteConsistentHashingRouterSpec.scala | 10 ++---
.../apache/pekko/remote/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeathWatchSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeployerSpec.scala | 4 +-
.../remote/classic/RemoteDeathWatchSpec.scala | 4 +-
.../jackson/JacksonSerializerSpec.scala | 4 +-
59 files changed, 215 insertions(+), 215 deletions(-)
diff --git a/actor-tests/src/test/scala/org/apache/pekko/actor/ActorPathSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/actor/ActorPathSpec.scala
index ce2db777d1..df3697d9fd 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/actor/ActorPathSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/actor/ActorPathSpec.scala
@@ -68,26 +68,26 @@ class ActorPathSpec extends AnyWordSpec with Matchers {
"create correct toStringWithAddress" in {
val local = Address("pekko", "mysys")
- val a = local.copy(host = Some("aaa"), port = Some(2552))
+ val a = local.copy(host = Some("aaa"), port = Some(7355))
val b = a.copy(host = Some("bb"))
val c = a.copy(host = Some("cccc"))
val root = RootActorPath(local)
- root.toStringWithAddress(a) should ===("pekko://mysys@aaa:2552/")
- (root / "user").toStringWithAddress(a) should ===("pekko://mysys@aaa:2552/user")
- (root / "user" / "foo").toStringWithAddress(a) should ===("pekko://mysys@aaa:2552/user/foo")
+ root.toStringWithAddress(a) should ===("pekko://mysys@aaa:7355/")
+ (root / "user").toStringWithAddress(a) should ===("pekko://mysys@aaa:7355/user")
+ (root / "user" / "foo").toStringWithAddress(a) should ===("pekko://mysys@aaa:7355/user/foo")
- // root.toStringWithAddress(b) should ===("pekko://mysys@bb:2552/")
- (root / "user").toStringWithAddress(b) should ===("pekko://mysys@bb:2552/user")
- (root / "user" / "foo").toStringWithAddress(b) should ===("pekko://mysys@bb:2552/user/foo")
+ // root.toStringWithAddress(b) should ===("pekko://mysys@bb:7355/")
+ (root / "user").toStringWithAddress(b) should ===("pekko://mysys@bb:7355/user")
+ (root / "user" / "foo").toStringWithAddress(b) should ===("pekko://mysys@bb:7355/user/foo")
- root.toStringWithAddress(c) should ===("pekko://mysys@cccc:2552/")
- (root / "user").toStringWithAddress(c) should ===("pekko://mysys@cccc:2552/user")
- (root / "user" / "foo").toStringWithAddress(c) should ===("pekko://mysys@cccc:2552/user/foo")
+ root.toStringWithAddress(c) should ===("pekko://mysys@cccc:7355/")
+ (root / "user").toStringWithAddress(c) should ===("pekko://mysys@cccc:7355/user")
+ (root / "user" / "foo").toStringWithAddress(c) should ===("pekko://mysys@cccc:7355/user/foo")
val rootA = RootActorPath(a)
- rootA.toStringWithAddress(b) should ===("pekko://mysys@aaa:2552/")
- (rootA / "user").toStringWithAddress(b) should ===("pekko://mysys@aaa:2552/user")
- (rootA / "user" / "foo").toStringWithAddress(b) should ===("pekko://mysys@aaa:2552/user/foo")
+ rootA.toStringWithAddress(b) should ===("pekko://mysys@aaa:7355/")
+ (rootA / "user").toStringWithAddress(b) should ===("pekko://mysys@aaa:7355/user")
+ (rootA / "user" / "foo").toStringWithAddress(b) should ===("pekko://mysys@aaa:7355/user/foo")
}
"not allow path separators in RootActorPath's name" in {
diff --git a/actor-tests/src/test/scala/org/apache/pekko/actor/LocalActorRefProviderSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/actor/LocalActorRefProviderSpec.scala
index 1a54df0821..3201e80022 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/actor/LocalActorRefProviderSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/actor/LocalActorRefProviderSpec.scala
@@ -48,7 +48,7 @@ class LocalActorRefProviderSpec extends PekkoSpec(LocalActorRefProviderSpec.conf
"An LocalActorRefProvider" must {
"find child actor with URL encoded name" in {
- val childName = "pekko%3A%2F%2FClusterSystem%40127.0.0.1%3A2552"
+ val childName = "pekko%3A%2F%2FClusterSystem%40127.0.0.1%3A7355"
val a = system.actorOf(Props(new Actor {
val child = context.actorOf(Props.empty, name = childName)
def receive = {
diff --git a/actor-tests/src/test/scala/org/apache/pekko/actor/RelativeActorPathSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/actor/RelativeActorPathSpec.scala
index 822965eaeb..8ab1836188 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/actor/RelativeActorPathSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/actor/RelativeActorPathSpec.scala
@@ -32,7 +32,7 @@ class RelativeActorPathSpec extends AnyWordSpec with Matchers {
elements("foo/bar/baz") should ===(List("foo", "bar", "baz"))
}
"match url encoded name" in {
- val name = URLEncoder.encode("pekko://ClusterSystem@127.0.0.1:2552", "UTF-8")
+ val name = URLEncoder.encode("pekko://ClusterSystem@127.0.0.1:7355", "UTF-8")
elements(name) should ===(List(name))
}
"match path with uid fragment" in {
diff --git a/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/ORSetMergeBenchmark.scala b/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/ORSetMergeBenchmark.scala
index 0072f4d263..4335c8f69e 100644
--- a/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/ORSetMergeBenchmark.scala
+++ b/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/ORSetMergeBenchmark.scala
@@ -43,7 +43,7 @@ class ORSetMergeBenchmark {
@Param(Array("1", "10", "20", "100"))
var set1Size = 0
- val nodeA = UniqueAddress(Address("pekko", "Sys", "aaaa", 2552), 1L)
+ val nodeA = UniqueAddress(Address("pekko", "Sys", "aaaa", 7355), 1L)
val nodeB = UniqueAddress(nodeA.address.copy(host = Some("bbbb")), 2L)
val nodeC = UniqueAddress(nodeA.address.copy(host = Some("cccc")), 3L)
val nodeD = UniqueAddress(nodeA.address.copy(host = Some("dddd")), 4L)
diff --git a/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/VersionVectorBenchmark.scala b/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/VersionVectorBenchmark.scala
index e466bb2e45..223f78575a 100644
--- a/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/VersionVectorBenchmark.scala
+++ b/bench-jmh/src/main/scala/org/apache/pekko/cluster/ddata/VersionVectorBenchmark.scala
@@ -43,7 +43,7 @@ class VersionVectorBenchmark {
@Param(Array("1", "2", "5"))
var size = 0
- val nodeA = UniqueAddress(Address("pekko", "Sys", "aaaa", 2552), 1L)
+ val nodeA = UniqueAddress(Address("pekko", "Sys", "aaaa", 7355), 1L)
val nodeB = UniqueAddress(nodeA.address.copy(host = Some("bbbb")), 2L)
val nodeC = UniqueAddress(nodeA.address.copy(host = Some("cccc")), 3L)
val nodeD = UniqueAddress(nodeA.address.copy(host = Some("dddd")), 4L)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/protobuf/MessageSerializerSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/protobuf/MessageSerializerSpec.scala
index 4cbc3ab09d..31c5cad413 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/protobuf/MessageSerializerSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/protobuf/MessageSerializerSpec.scala
@@ -40,12 +40,12 @@ class MessageSerializerSpec extends PekkoSpec("""
import MemberStatus._
- val a1 = TestMember(Address("pekko", "sys", "a", 2552), Joining, Set.empty)
- val b1 = TestMember(Address("pekko", "sys", "b", 2552), Up, Set("r1"))
- val c1 = TestMember(Address("pekko", "sys", "c", 2552), Leaving, Set("r2"))
- val d1 = TestMember(Address("pekko", "sys", "d", 2552), Exiting, Set("r1", "r2"))
- val e1 = TestMember(Address("pekko", "sys", "e", 2552), Down, Set("r3"))
- val f1 = TestMember(Address("pekko", "sys", "f", 2552), Removed, Set("r2", "r3"))
+ val a1 = TestMember(Address("pekko", "sys", "a", 7355), Joining, Set.empty)
+ val b1 = TestMember(Address("pekko", "sys", "b", 7355), Up, Set("r1"))
+ val c1 = TestMember(Address("pekko", "sys", "c", 7355), Leaving, Set("r2"))
+ val d1 = TestMember(Address("pekko", "sys", "d", 7355), Exiting, Set("r1", "r2"))
+ val e1 = TestMember(Address("pekko", "sys", "e", 7355), Down, Set("r3"))
+ val f1 = TestMember(Address("pekko", "sys", "f", 7355), Removed, Set("r2", "r3"))
"ClusterMessages" must {
diff --git a/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlyTest.java b/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlyTest.java
index 6308f0a0d8..c367b20404 100644
--- a/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlyTest.java
+++ b/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlyTest.java
@@ -46,7 +46,7 @@ public class ExternalShardAllocationCompileOnlyTest {
ExternalShardAllocationClient client =
ExternalShardAllocation.get(system).getClient(typeKey.name());
CompletionStage<Done> done =
- client.setShardLocation("shard-id-1", new Address("pekko", "system", "127.0.0.1", 2552));
+ client.setShardLocation("shard-id-1", new Address("pekko", "system", "127.0.0.1", 7355));
// #client
}
diff --git a/cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlySpec.scala b/cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlySpec.scala
index 40fb31e225..2217a00553 100644
--- a/cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlySpec.scala
+++ b/cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlySpec.scala
@@ -46,7 +46,7 @@ class ExternalShardAllocationCompileOnlySpec {
// #client
val client: ExternalShardAllocationClient = ExternalShardAllocation(system).clientFor(TypeKey.name)
- val done: Future[Done] = client.updateShardLocation("shard-id-1", Address("pekko", "system", "127.0.0.1", 2552))
+ val done: Future[Done] = client.updateShardLocation("shard-id-1", Address("pekko", "system", "127.0.0.1", 7355))
// #client
}
diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializerSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializerSpec.scala
index 7e0e9eed2e..6d65f8889b 100644
--- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializerSpec.scala
+++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializerSpec.scala
@@ -121,15 +121,15 @@ class ClusterShardingMessageSerializerSpec extends PekkoSpec {
"be able to serialize GetCurrentRegions" in {
checkSerialization(ShardRegion.GetCurrentRegions)
checkSerialization(
- ShardRegion.CurrentRegions(Set(Address("pekko", "sys", "a", 2552), Address("pekko", "sys", "b", 2552))))
+ ShardRegion.CurrentRegions(Set(Address("pekko", "sys", "a", 7355), Address("pekko", "sys", "b", 7355))))
}
"be able to serialize GetClusterShardingStats" in {
checkSerialization(ShardRegion.GetClusterShardingStats(3.seconds))
checkSerialization(
ShardRegion.ClusterShardingStats(Map(
- Address("pekko", "sys", "a", 2552) -> ShardRegion.ShardRegionStats(Map[ShardId, Int]("a" -> 23), Set("b")),
- Address("pekko", "sys", "b", 2552) -> ShardRegion.ShardRegionStats(Map[ShardId, Int]("a" -> 23), Set("b")))))
+ Address("pekko", "sys", "a", 7355) -> ShardRegion.ShardRegionStats(Map[ShardId, Int]("a" -> 23), Set("b")),
+ Address("pekko", "sys", "b", 7355) -> ShardRegion.ShardRegionStats(Map[ShardId, Int]("a" -> 23), Set("b")))))
}
}
}
diff --git a/cluster-tools/src/multi-jvm/scala/org/apache/pekko/cluster/client/ClusterClientSpec.scala b/cluster-tools/src/multi-jvm/scala/org/apache/pekko/cluster/client/ClusterClientSpec.scala
index 5ca698c9ed..91edc7e97b 100644
--- a/cluster-tools/src/multi-jvm/scala/org/apache/pekko/cluster/client/ClusterClientSpec.scala
+++ b/cluster-tools/src/multi-jvm/scala/org/apache/pekko/cluster/client/ClusterClientSpec.scala
@@ -205,8 +205,8 @@ class ClusterClientSpec extends MultiNodeSpec(ClusterClientSpec) with STMultiNod
def docOnly = { // not used, only demo
// #initialContacts
val initialContacts = Set(
- ActorPath.fromString("pekko://OtherSys@host1:2552/system/receptionist"),
- ActorPath.fromString("pekko://OtherSys@host2:2552/system/receptionist"))
+ ActorPath.fromString("pekko://OtherSys@host1:7355/system/receptionist"),
+ ActorPath.fromString("pekko://OtherSys@host2:7355/system/receptionist"))
val settings = ClusterClientSettings(system).withInitialContacts(initialContacts)
// #initialContacts
diff --git a/cluster-tools/src/test/java/org/apache/pekko/cluster/client/ClusterClientTest.java b/cluster-tools/src/test/java/org/apache/pekko/cluster/client/ClusterClientTest.java
index 974c1ac42c..43afaf7253 100644
--- a/cluster-tools/src/test/java/org/apache/pekko/cluster/client/ClusterClientTest.java
+++ b/cluster-tools/src/test/java/org/apache/pekko/cluster/client/ClusterClientTest.java
@@ -41,8 +41,8 @@ public class ClusterClientTest extends JUnitSuite {
Set<ActorPath> initialContacts() {
return new HashSet<ActorPath>(
Arrays.asList(
- ActorPaths.fromString("pekko://OtherSys@host1:2552/system/receptionist"),
- ActorPaths.fromString("pekko://OtherSys@host2:2552/system/receptionist")));
+ ActorPaths.fromString("pekko://OtherSys@host1:7355/system/receptionist"),
+ ActorPaths.fromString("pekko://OtherSys@host2:7355/system/receptionist")));
}
// #initialContacts
diff --git a/cluster-tools/src/test/scala/org/apache/pekko/cluster/client/protobuf/ClusterClientMessageSerializerSpec.scala b/cluster-tools/src/test/scala/org/apache/pekko/cluster/client/protobuf/ClusterClientMessageSerializerSpec.scala
index 65879d790a..0d0eee5aaf 100644
--- a/cluster-tools/src/test/scala/org/apache/pekko/cluster/client/protobuf/ClusterClientMessageSerializerSpec.scala
+++ b/cluster-tools/src/test/scala/org/apache/pekko/cluster/client/protobuf/ClusterClientMessageSerializerSpec.scala
@@ -35,9 +35,9 @@ class ClusterClientMessageSerializerSpec extends PekkoSpec {
"be serializable" in {
val contactPoints = Vector(
- "pekko://system@node-1:2552/system/receptionist",
- "pekko://system@node-2:2552/system/receptionist",
- "pekko://system@node-3:2552/system/receptionist")
+ "pekko://system@node-1:7355/system/receptionist",
+ "pekko://system@node-2:7355/system/receptionist",
+ "pekko://system@node-3:7355/system/receptionist")
checkSerialization(Contacts(contactPoints))
checkSerialization(GetContacts)
checkSerialization(Heartbeat)
diff --git a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
index 1031e2a313..b92d3d01e2 100644
--- a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
+++ b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
@@ -132,7 +132,7 @@ public class BasicClusterExampleTest { // extends JUnitSuite {
// #join-seed-nodes
List<Address> seedNodes = new ArrayList<>();
seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:2551"));
- seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:2552"));
+ seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:7355"));
Cluster.get(system).manager().tell(new JoinSeedNodes(seedNodes));
// #join-seed-nodes
diff --git a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
index a1a5846c0e..6e3a4a13e8 100644
--- a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
+++ b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
@@ -53,7 +53,7 @@ pekko {
cluster {
seed-nodes = [
"pekko://ClusterSystem@127.0.0.1:2551",
- "pekko://ClusterSystem@127.0.0.1:2552"]
+ "pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = "org.apache.pekko.cluster.sbr.SplitBrainResolverProvider"
}
@@ -75,7 +75,7 @@ pekko {
import pekko.cluster.typed.JoinSeedNodes
val seedNodes: List[Address] =
- List("pekko://ClusterSystem@127.0.0.1:2551", "pekko://ClusterSystem@127.0.0.1:2552").map(
+ List("pekko://ClusterSystem@127.0.0.1:2551", "pekko://ClusterSystem@127.0.0.1:7355").map(
AddressFromURIString.parse)
Cluster(system).manager ! JoinSeedNodes(seedNodes)
// #join-seed-nodes
diff --git a/cluster/jmx-client/pekko-cluster b/cluster/jmx-client/pekko-cluster
index 216b14491b..2bb59b63a4 100755
--- a/cluster/jmx-client/pekko-cluster
+++ b/cluster/jmx-client/pekko-cluster
@@ -217,10 +217,10 @@ do
printf "Where the <node-url> should be on the format of 'pekko.tcp://actor-system-name@hostname:port'\n"
printf "\n"
printf "Examples: $0 localhost 9999 is-available\n"
- printf " $0 localhost 9999 join pekko.tcp://MySystem@darkstar:2552\n"
+ printf " $0 localhost 9999 join pekko.tcp://MySystem@darkstar:7355\n"
printf " $0 localhost 9999 cluster-status\n"
printf " $0 localhost 9999 -p 2551 is-available\n"
- printf " $0 localhost 9999 -p 2551 join pekko.tcp://MySystem@darkstar:2552\n"
+ printf " $0 localhost 9999 -p 2551 join pekko.tcp://MySystem@darkstar:7355\n"
printf " $0 localhost 9999 -p 2551 cluster-status\n"
exit 1
;;
diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/ClusterJmx.scala b/cluster/src/main/scala/org/apache/pekko/cluster/ClusterJmx.scala
index 0ddafa3dfd..84633febf9 100644
--- a/cluster/src/main/scala/org/apache/pekko/cluster/ClusterJmx.scala
+++ b/cluster/src/main/scala/org/apache/pekko/cluster/ClusterJmx.scala
@@ -49,10 +49,10 @@ trait ClusterNodeMBean {
* JSON format of the status of all nodes in the cluster as follows:
* {{{
* {
- * "self-address": "pekko://system@host1:2552",
+ * "self-address": "pekko://system@host1:7355",
* "members": [
* {
- * "address": "pekko://system@host1:2552",
+ * "address": "pekko://system@host1:7355",
* "status": "Up",
* "app-version": "1.0.0",
* "roles": [
@@ -60,7 +60,7 @@ trait ClusterNodeMBean {
* ]
* },
* {
- * "address": "pekko://system@host2:2552",
+ * "address": "pekko://system@host2:7355",
* "status": "Up",
* "app-version": "1.0.0",
* "roles": [
@@ -68,7 +68,7 @@ trait ClusterNodeMBean {
* ]
* },
* {
- * "address": "pekko://system@host3:2552",
+ * "address": "pekko://system@host3:7355",
* "status": "Down",
* "app-version": "1.0.0",
* "roles": [
@@ -76,7 +76,7 @@ trait ClusterNodeMBean {
* ]
* },
* {
- * "address": "pekko://system@host4:2552",
+ * "address": "pekko://system@host4:7355",
* "status": "Joining",
* "app-version": "1.1.0",
* "roles": [
@@ -86,17 +86,17 @@ trait ClusterNodeMBean {
* ],
* "unreachable": [
* {
- * "node": "pekko://system@host2:2552",
+ * "node": "pekko://system@host2:7355",
* "observed-by": [
- * "pekko://system@host1:2552",
- * "pekko://system@host3:2552"
+ * "pekko://system@host1:7355",
+ * "pekko://system@host3:7355"
* ]
* },
* {
- * "node": "pekko://system@host3:2552",
+ * "node": "pekko://system@host3:7355",
* "observed-by": [
- * "pekko://system@host1:2552",
- * "pekko://system@host2:2552"
+ * "pekko://system@host1:7355",
+ * "pekko://system@host2:7355"
* ]
* }
* ]
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
index ebd02a1b5f..3df03b3147 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
@@ -52,18 +52,18 @@ class ClusterDomainEventPublisherSpec
final val OtherDataCenter = "dc2"
- val aUp = TestMember(Address(protocol, "sys", "a", 2552), Up)
+ val aUp = TestMember(Address(protocol, "sys", "a", 7355), Up)
val aLeaving = aUp.copy(status = Leaving)
val aExiting = aLeaving.copy(status = Exiting)
val aRemoved = aExiting.copy(status = Removed)
- val bExiting = TestMember(Address(protocol, "sys", "b", 2552), Exiting)
+ val bExiting = TestMember(Address(protocol, "sys", "b", 7355), Exiting)
val bRemoved = bExiting.copy(status = Removed)
- val cJoining = TestMember(Address(protocol, "sys", "c", 2552), Joining, Set("GRP"))
+ val cJoining = TestMember(Address(protocol, "sys", "c", 7355), Joining, Set("GRP"))
val cUp = cJoining.copy(status = Up)
val cRemoved = cUp.copy(status = Removed)
val a51Up = TestMember(Address(protocol, "sys", "a", 2551), Up)
- val dUp = TestMember(Address(protocol, "sys", "d", 2552), Up, Set("GRP"))
- val eUp = TestMember(Address(protocol, "sys", "e", 2552), Up, Set("GRP"), OtherDataCenter)
+ val dUp = TestMember(Address(protocol, "sys", "d", 7355), Up, Set("GRP"))
+ val eUp = TestMember(Address(protocol, "sys", "e", 7355), Up, Set("GRP"), OtherDataCenter)
private def state(gossip: Gossip, self: UniqueAddress) =
MembershipState(gossip, self, DefaultDataCenter, crossDcConnections = 5)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventSpec.scala
index 6b28d342e1..870bffe470 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventSpec.scala
@@ -25,25 +25,25 @@ class ClusterDomainEventSpec extends AnyWordSpec with Matchers with BeforeAndAft
import MemberStatus._
val aRoles = Set("AA", "AB")
- val aJoining = TestMember(Address("pekko", "sys", "a", 2552), Joining, aRoles)
- val aUp = TestMember(Address("pekko", "sys", "a", 2552), Up, aRoles)
- val aRemoved = TestMember(Address("pekko", "sys", "a", 2552), Removed, aRoles)
+ val aJoining = TestMember(Address("pekko", "sys", "a", 7355), Joining, aRoles)
+ val aUp = TestMember(Address("pekko", "sys", "a", 7355), Up, aRoles)
+ val aRemoved = TestMember(Address("pekko", "sys", "a", 7355), Removed, aRoles)
val bRoles = Set("AB", "BB")
- val bUp = TestMember(Address("pekko", "sys", "b", 2552), Up, bRoles)
- val bDown = TestMember(Address("pekko", "sys", "b", 2552), Down, bRoles)
- val bRemoved = TestMember(Address("pekko", "sys", "b", 2552), Removed, bRoles)
+ val bUp = TestMember(Address("pekko", "sys", "b", 7355), Up, bRoles)
+ val bDown = TestMember(Address("pekko", "sys", "b", 7355), Down, bRoles)
+ val bRemoved = TestMember(Address("pekko", "sys", "b", 7355), Removed, bRoles)
val cRoles = Set.empty[String]
- val cUp = TestMember(Address("pekko", "sys", "c", 2552), Up, cRoles)
- val cLeaving = TestMember(Address("pekko", "sys", "c", 2552), Leaving, cRoles)
+ val cUp = TestMember(Address("pekko", "sys", "c", 7355), Up, cRoles)
+ val cLeaving = TestMember(Address("pekko", "sys", "c", 7355), Leaving, cRoles)
val dRoles = Set("DD", "DE")
- val dLeaving = TestMember(Address("pekko", "sys", "d", 2552), Leaving, dRoles)
- val dExiting = TestMember(Address("pekko", "sys", "d", 2552), Exiting, dRoles)
- val dRemoved = TestMember(Address("pekko", "sys", "d", 2552), Removed, dRoles)
+ val dLeaving = TestMember(Address("pekko", "sys", "d", 7355), Leaving, dRoles)
+ val dExiting = TestMember(Address("pekko", "sys", "d", 7355), Exiting, dRoles)
+ val dRemoved = TestMember(Address("pekko", "sys", "d", 7355), Removed, dRoles)
val eRoles = Set("EE", "DE")
- val eJoining = TestMember(Address("pekko", "sys", "e", 2552), Joining, eRoles)
- val eUp = TestMember(Address("pekko", "sys", "e", 2552), Up, eRoles)
- val eDown = TestMember(Address("pekko", "sys", "e", 2552), Down, eRoles)
- val selfDummyAddress = UniqueAddress(Address("pekko", "sys", "selfDummy", 2552), 17L)
+ val eJoining = TestMember(Address("pekko", "sys", "e", 7355), Joining, eRoles)
+ val eUp = TestMember(Address("pekko", "sys", "e", 7355), Up, eRoles)
+ val eDown = TestMember(Address("pekko", "sys", "e", 7355), Down, eRoles)
+ val selfDummyAddress = UniqueAddress(Address("pekko", "sys", "selfDummy", 7355), 17L)
private val originalClusterAssert = sys.props.get("pekko.cluster.assert").getOrElse("false")
override protected def beforeAll(): Unit = {
@@ -109,12 +109,12 @@ class ClusterDomainEventSpec extends AnyWordSpec with Matchers with BeforeAndAft
}
"be produced for reachability observations between data centers" in {
- val dc2AMemberUp = TestMember(Address("pekko", "sys", "dc2A", 2552), Up, Set.empty[String], "dc2")
- val dc2AMemberDown = TestMember(Address("pekko", "sys", "dc2A", 2552), Down, Set.empty[String], "dc2")
- val dc2BMemberUp = TestMember(Address("pekko", "sys", "dc2B", 2552), Up, Set.empty[String], "dc2")
+ val dc2AMemberUp = TestMember(Address("pekko", "sys", "dc2A", 7355), Up, Set.empty[String], "dc2")
+ val dc2AMemberDown = TestMember(Address("pekko", "sys", "dc2A", 7355), Down, Set.empty[String], "dc2")
+ val dc2BMemberUp = TestMember(Address("pekko", "sys", "dc2B", 7355), Up, Set.empty[String], "dc2")
- val dc3AMemberUp = TestMember(Address("pekko", "sys", "dc3A", 2552), Up, Set.empty[String], "dc3")
- val dc3BMemberUp = TestMember(Address("pekko", "sys", "dc3B", 2552), Up, Set.empty[String], "dc3")
+ val dc3AMemberUp = TestMember(Address("pekko", "sys", "dc3A", 7355), Up, Set.empty[String], "dc3")
+ val dc3BMemberUp = TestMember(Address("pekko", "sys", "dc3B", 7355), Up, Set.empty[String], "dc3")
val reachability1 = Reachability.empty
val g1 = Gossip(
@@ -146,8 +146,8 @@ class ClusterDomainEventSpec extends AnyWordSpec with Matchers with BeforeAndAft
}
"not be produced for same reachability observations between data centers" in {
- val dc2AMemberUp = TestMember(Address("pekko", "sys", "dc2A", 2552), Up, Set.empty[String], "dc2")
- val dc2AMemberDown = TestMember(Address("pekko", "sys", "dc2A", 2552), Down, Set.empty[String], "dc2")
+ val dc2AMemberUp = TestMember(Address("pekko", "sys", "dc2A", 7355), Up, Set.empty[String], "dc2")
+ val dc2AMemberDown = TestMember(Address("pekko", "sys", "dc2A", 7355), Down, Set.empty[String], "dc2")
val reachability1 = Reachability.empty
val g1 = Gossip(members = SortedSet(aUp, dc2AMemberUp), overview = GossipOverview(reachability = reachability1))
@@ -181,9 +181,9 @@ class ClusterDomainEventSpec extends AnyWordSpec with Matchers with BeforeAndAft
// - empty
// - B --unreachable--> C
- val dc1MemberA = TestMember(Address("pekko", "sys", "dc2A", 2552), Up, Set.empty[String], "dc2")
- val dc1MemberB = TestMember(Address("pekko", "sys", "dc2B", 2552), Up, Set.empty[String], "dc2")
- val dc2MemberC = TestMember(Address("pekko", "sys", "dc3A", 2552), Up, Set.empty[String], "dc3")
+ val dc1MemberA = TestMember(Address("pekko", "sys", "dc2A", 7355), Up, Set.empty[String], "dc2")
+ val dc1MemberB = TestMember(Address("pekko", "sys", "dc2B", 7355), Up, Set.empty[String], "dc2")
+ val dc2MemberC = TestMember(Address("pekko", "sys", "dc3A", 7355), Up, Set.empty[String], "dc3")
val members = SortedSet(dc1MemberA, dc1MemberB, dc2MemberC)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderStateSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderStateSpec.scala
index afc556ce02..27f8e4e3fd 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderStateSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderStateSpec.scala
@@ -52,11 +52,11 @@ object ClusterHeartbeatSenderStateSpec {
class ClusterHeartbeatSenderStateSpec extends AnyWordSpec with Matchers {
import ClusterHeartbeatSenderStateSpec._
- val aa = UniqueAddress(Address("pekko", "sys", "aa", 2552), 1L)
- val bb = UniqueAddress(Address("pekko", "sys", "bb", 2552), 2L)
- val cc = UniqueAddress(Address("pekko", "sys", "cc", 2552), 3L)
- val dd = UniqueAddress(Address("pekko", "sys", "dd", 2552), 4L)
- val ee = UniqueAddress(Address("pekko", "sys", "ee", 2552), 5L)
+ val aa = UniqueAddress(Address("pekko", "sys", "aa", 7355), 1L)
+ val bb = UniqueAddress(Address("pekko", "sys", "bb", 7355), 2L)
+ val cc = UniqueAddress(Address("pekko", "sys", "cc", 7355), 3L)
+ val dd = UniqueAddress(Address("pekko", "sys", "dd", 7355), 4L)
+ val ee = UniqueAddress(Address("pekko", "sys", "ee", 7355), 5L)
private def emptyState: ClusterHeartbeatSenderState = emptyState(aa)
@@ -164,7 +164,7 @@ class ClusterHeartbeatSenderStateSpec extends AnyWordSpec with Matchers {
"behave correctly for random operations" in {
val rnd = ThreadLocalRandom.current
val nodes =
- (1 to rnd.nextInt(10, 200)).map(n => UniqueAddress(Address("pekko", "sys", "n" + n, 2552), n.toLong)).toVector
+ (1 to rnd.nextInt(10, 200)).map(n => UniqueAddress(Address("pekko", "sys", "n" + n, 7355), n.toLong)).toVector
def rndNode() = nodes(rnd.nextInt(0, nodes.size))
val selfUniqueAddress = rndNode()
var state = emptyState(selfUniqueAddress)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
index 368e1ddd81..7de9e559a9 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala
@@ -357,14 +357,14 @@ class ClusterSpec extends PekkoSpec(ClusterSpec.config) with ImplicitSender {
pekko.remote.artery.canonical.port = ${port}
""").withFallback(ConfigFactory.parseString(ClusterSpec.config))
- val sys1 = ActorSystem("ClusterSpec4", getConfig(2552))
+ val sys1 = ActorSystem("ClusterSpec4", getConfig(7355))
val sys2 = ActorSystem("ClusterSpec4", getConfig(2553))
try {
Cluster(sys1)
Cluster(sys2)
- val name1 = new ObjectName(s"pekko:type=Cluster,port=2552")
+ val name1 = new ObjectName(s"pekko:type=Cluster,port=7355")
val info1 = ManagementFactory.getPlatformMBeanServer.getMBeanInfo(name1)
info1.getAttributes.length should be > 0
info1.getOperations.length should be > 0
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/GossipSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/GossipSpec.scala
index 089a75a619..dd92adbe01 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/GossipSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/GossipSpec.scala
@@ -27,23 +27,23 @@ class GossipSpec extends AnyWordSpec with Matchers {
import MemberStatus._
- val a1 = TestMember(Address("pekko", "sys", "a", 2552), Up)
+ val a1 = TestMember(Address("pekko", "sys", "a", 7355), Up)
val a2 = TestMember(a1.address, Joining)
- val b1 = TestMember(Address("pekko", "sys", "b", 2552), Up)
+ val b1 = TestMember(Address("pekko", "sys", "b", 7355), Up)
val b2 = TestMember(b1.address, Removed)
- val c1 = TestMember(Address("pekko", "sys", "c", 2552), Leaving)
+ val c1 = TestMember(Address("pekko", "sys", "c", 7355), Leaving)
val c2 = TestMember(c1.address, Up)
val c3 = TestMember(c1.address, Exiting)
- val d1 = TestMember(Address("pekko", "sys", "d", 2552), Leaving)
- val e1 = TestMember(Address("pekko", "sys", "e", 2552), Joining)
+ val d1 = TestMember(Address("pekko", "sys", "d", 7355), Leaving)
+ val e1 = TestMember(Address("pekko", "sys", "e", 7355), Joining)
val e2 = TestMember(e1.address, Up)
val e3 = TestMember(e1.address, Down)
- val f1 = TestMember(Address("pekko", "sys", "f", 2552), Joining)
+ val f1 = TestMember(Address("pekko", "sys", "f", 7355), Joining)
- val dc1a1 = TestMember(Address("pekko", "sys", "a", 2552), Up, Set.empty, dataCenter = "dc1")
- val dc1b1 = TestMember(Address("pekko", "sys", "b", 2552), Up, Set.empty, dataCenter = "dc1")
- val dc2c1 = TestMember(Address("pekko", "sys", "c", 2552), Up, Set.empty, dataCenter = "dc2")
- val dc2d1 = TestMember(Address("pekko", "sys", "d", 2552), Up, Set.empty, dataCenter = "dc2")
+ val dc1a1 = TestMember(Address("pekko", "sys", "a", 7355), Up, Set.empty, dataCenter = "dc1")
+ val dc1b1 = TestMember(Address("pekko", "sys", "b", 7355), Up, Set.empty, dataCenter = "dc1")
+ val dc2c1 = TestMember(Address("pekko", "sys", "c", 7355), Up, Set.empty, dataCenter = "dc2")
+ val dc2d1 = TestMember(Address("pekko", "sys", "d", 7355), Up, Set.empty, dataCenter = "dc2")
val dc2d2 = TestMember(dc2d1.address, status = Down, roles = Set.empty, dataCenter = dc2d1.dataCenter)
// restarted with another uid
val dc2d3 =
@@ -533,7 +533,7 @@ class GossipSpec extends AnyWordSpec with Matchers {
}
"update members" in {
- val joining = TestMember(Address("pekko", "sys", "d", 2552), Joining, Set.empty, dataCenter = "dc2")
+ val joining = TestMember(Address("pekko", "sys", "d", 7355), Joining, Set.empty, dataCenter = "dc2")
val g = Gossip(members = SortedSet(dc1a1, joining))
g.member(joining.uniqueAddress).status should ===(Joining)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/GossipTargetSelectorSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/GossipTargetSelectorSpec.scala
index 9da93fbfd7..5279a5d275 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/GossipTargetSelectorSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/GossipTargetSelectorSpec.scala
@@ -25,17 +25,17 @@ import pekko.cluster.MemberStatus.Up
class GossipTargetSelectorSpec extends AnyWordSpec with Matchers {
- val aDc1 = TestMember(Address("pekko", "sys", "a", 2552), Up, Set.empty, dataCenter = "dc1")
- val bDc1 = TestMember(Address("pekko", "sys", "b", 2552), Up, Set.empty, dataCenter = "dc1")
- val cDc1 = TestMember(Address("pekko", "sys", "c", 2552), Up, Set.empty, dataCenter = "dc1")
+ val aDc1 = TestMember(Address("pekko", "sys", "a", 7355), Up, Set.empty, dataCenter = "dc1")
+ val bDc1 = TestMember(Address("pekko", "sys", "b", 7355), Up, Set.empty, dataCenter = "dc1")
+ val cDc1 = TestMember(Address("pekko", "sys", "c", 7355), Up, Set.empty, dataCenter = "dc1")
- val eDc2 = TestMember(Address("pekko", "sys", "e", 2552), Up, Set.empty, dataCenter = "dc2")
- val fDc2 = TestMember(Address("pekko", "sys", "f", 2552), Up, Set.empty, dataCenter = "dc2")
+ val eDc2 = TestMember(Address("pekko", "sys", "e", 7355), Up, Set.empty, dataCenter = "dc2")
+ val fDc2 = TestMember(Address("pekko", "sys", "f", 7355), Up, Set.empty, dataCenter = "dc2")
- val gDc3 = TestMember(Address("pekko", "sys", "g", 2552), Up, Set.empty, dataCenter = "dc3")
- val hDc3 = TestMember(Address("pekko", "sys", "h", 2552), Up, Set.empty, dataCenter = "dc3")
+ val gDc3 = TestMember(Address("pekko", "sys", "g", 7355), Up, Set.empty, dataCenter = "dc3")
+ val hDc3 = TestMember(Address("pekko", "sys", "h", 7355), Up, Set.empty, dataCenter = "dc3")
- val iDc4 = TestMember(Address("pekko", "sys", "i", 2552), Up, Set.empty, dataCenter = "dc4")
+ val iDc4 = TestMember(Address("pekko", "sys", "i", 7355), Up, Set.empty, dataCenter = "dc4")
val defaultSelector =
new GossipTargetSelector(reduceGossipDifferentViewProbability = 400, crossDcGossipProbability = 0.2)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingPerfSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingPerfSpec.scala
index ac1d8ea596..922b7e89a8 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingPerfSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingPerfSpec.scala
@@ -26,7 +26,7 @@ class HeartbeatNodeRingPerfSpec extends AnyWordSpec with Matchers {
sys.props.get("org.apache.pekko.cluster.HeartbeatNodeRingPerfSpec.iterations").getOrElse("1000").toInt
def createHeartbeatNodeRingOfSize(size: Int): HeartbeatNodeRing = {
- val nodes = (1 to size).map(n => UniqueAddress(Address("pekko", "sys", "node-" + n, 2552), n.toLong))
+ val nodes = (1 to size).map(n => UniqueAddress(Address("pekko", "sys", "node-" + n, 7355), n.toLong))
val selfAddress = nodes(size / 2)
HeartbeatNodeRing(selfAddress, nodes.toSet, Set.empty, 5)
}
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingSpec.scala
index 46114e75b8..0fe35523aa 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingSpec.scala
@@ -20,12 +20,12 @@ import org.apache.pekko.actor.Address
class HeartbeatNodeRingSpec extends AnyWordSpec with Matchers {
- val aa = UniqueAddress(Address("pekko", "sys", "aa", 2552), 1L)
- val bb = UniqueAddress(Address("pekko", "sys", "bb", 2552), 2L)
- val cc = UniqueAddress(Address("pekko", "sys", "cc", 2552), 3L)
- val dd = UniqueAddress(Address("pekko", "sys", "dd", 2552), 4L)
- val ee = UniqueAddress(Address("pekko", "sys", "ee", 2552), 5L)
- val ff = UniqueAddress(Address("pekko", "sys", "ff", 2552), 6L)
+ val aa = UniqueAddress(Address("pekko", "sys", "aa", 7355), 1L)
+ val bb = UniqueAddress(Address("pekko", "sys", "bb", 7355), 2L)
+ val cc = UniqueAddress(Address("pekko", "sys", "cc", 7355), 3L)
+ val dd = UniqueAddress(Address("pekko", "sys", "dd", 7355), 4L)
+ val ee = UniqueAddress(Address("pekko", "sys", "ee", 7355), 5L)
+ val ff = UniqueAddress(Address("pekko", "sys", "ff", 7355), 6L)
val nodes = Set(aa, bb, cc, dd, ee, ff)
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/MembershipStateSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/MembershipStateSpec.scala
index 399080f4b0..ff2f2c9aee 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/MembershipStateSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/MembershipStateSpec.scala
@@ -24,18 +24,18 @@ import pekko.cluster.MemberStatus.Up
class MembershipStateSpec extends AnyWordSpec with Matchers {
// DC-a is in reverse age order
- val a1 = TestMember(Address("pekko", "sys", "a4", 2552), Up, 1, "dc-a")
- val a2 = TestMember(Address("pekko", "sys", "a3", 2552), Up, 2, "dc-a")
- val a3 = TestMember(Address("pekko", "sys", "a2", 2552), Up, 3, "dc-a")
- val a4 = TestMember(Address("pekko", "sys", "a1", 2552), Up, 4, "dc-a")
+ val a1 = TestMember(Address("pekko", "sys", "a4", 7355), Up, 1, "dc-a")
+ val a2 = TestMember(Address("pekko", "sys", "a3", 7355), Up, 2, "dc-a")
+ val a3 = TestMember(Address("pekko", "sys", "a2", 7355), Up, 3, "dc-a")
+ val a4 = TestMember(Address("pekko", "sys", "a1", 7355), Up, 4, "dc-a")
// DC-b it is the first and the last that are the oldest
- val b1 = TestMember(Address("pekko", "sys", "b3", 2552), Up, 1, "dc-b")
- val b3 = TestMember(Address("pekko", "sys", "b2", 2552), Up, 3, "dc-b")
+ val b1 = TestMember(Address("pekko", "sys", "b3", 7355), Up, 1, "dc-b")
+ val b3 = TestMember(Address("pekko", "sys", "b2", 7355), Up, 3, "dc-b")
// Won't be replaced by b3
- val b2 = TestMember(Address("pekko", "sys", "b1", 2552), Up, 2, "dc-b")
+ val b2 = TestMember(Address("pekko", "sys", "b1", 7355), Up, 2, "dc-b")
// for the case that we don't replace it ever
- val bOldest = TestMember(Address("pekko", "sys", "b0", 2552), Up, 0, "dc-b")
+ val bOldest = TestMember(Address("pekko", "sys", "b0", 7355), Up, 0, "dc-b")
"Membership state" must {
"sort by upNumber for oldest top members" in {
@@ -64,43 +64,43 @@ class MembershipStateSpec extends AnyWordSpec with Matchers {
"find two oldest per role as targets for Exiting change" in {
val a5 = TestMember(
- Address("pekko", "sys", "a5", 2552),
+ Address("pekko", "sys", "a5", 7355),
MemberStatus.Exiting,
roles = Set("role1", "role2"),
upNumber = 5,
dataCenter = "dc-a")
val a6 = TestMember(
- Address("pekko", "sys", "a6", 2552),
+ Address("pekko", "sys", "a6", 7355),
MemberStatus.Exiting,
roles = Set("role1", "role3"),
upNumber = 6,
dataCenter = "dc-a")
val a7 = TestMember(
- Address("pekko", "sys", "a7", 2552),
+ Address("pekko", "sys", "a7", 7355),
MemberStatus.Exiting,
roles = Set("role1"),
upNumber = 7,
dataCenter = "dc-a")
val a8 = TestMember(
- Address("pekko", "sys", "a8", 2552),
+ Address("pekko", "sys", "a8", 7355),
MemberStatus.Exiting,
roles = Set("role1"),
upNumber = 8,
dataCenter = "dc-a")
val a9 = TestMember(
- Address("pekko", "sys", "a9", 2552),
+ Address("pekko", "sys", "a9", 7355),
MemberStatus.Exiting,
roles = Set("role2"),
upNumber = 9,
dataCenter = "dc-a")
val b5 = TestMember(
- Address("pekko", "sys", "b5", 2552),
+ Address("pekko", "sys", "b5", 7355),
MemberStatus.Exiting,
roles = Set("role1"),
upNumber = 5,
dataCenter = "dc-b")
val b6 = TestMember(
- Address("pekko", "sys", "b6", 2552),
+ Address("pekko", "sys", "b6", 7355),
MemberStatus.Exiting,
roles = Set("role2"),
upNumber = 6,
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
index b6d8eff1be..b11ca6e81a 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
@@ -25,8 +25,8 @@ class ReachabilityPerfSpec extends AnyWordSpec with Matchers {
// increase for serious measurements
val iterations = sys.props.get("org.apache.pekko.cluster.ReachabilityPerfSpec.iterations").getOrElse("100").toInt
- val address = Address("pekko", "sys", "a", 2552)
- val node = Address("pekko", "sys", "a", 2552)
+ val address = Address("pekko", "sys", "a", 7355)
+ val node = Address("pekko", "sys", "a", 7355)
private def createReachabilityOfSize(base: Reachability, size: Int): Reachability =
(1 to size).foldLeft(base) {
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilitySpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilitySpec.scala
index 2884bcdb1b..6969dd0c12 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilitySpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilitySpec.scala
@@ -22,11 +22,11 @@ class ReachabilitySpec extends AnyWordSpec with Matchers {
import Reachability.{ Reachable, Record, Terminated, Unreachable }
- val nodeA = UniqueAddress(Address("pekko", "sys", "a", 2552), 1L)
- val nodeB = UniqueAddress(Address("pekko", "sys", "b", 2552), 2L)
- val nodeC = UniqueAddress(Address("pekko", "sys", "c", 2552), 3L)
- val nodeD = UniqueAddress(Address("pekko", "sys", "d", 2552), 4L)
- val nodeE = UniqueAddress(Address("pekko", "sys", "e", 2552), 5L)
+ val nodeA = UniqueAddress(Address("pekko", "sys", "a", 7355), 1L)
+ val nodeB = UniqueAddress(Address("pekko", "sys", "b", 7355), 2L)
+ val nodeC = UniqueAddress(Address("pekko", "sys", "c", 7355), 3L)
+ val nodeD = UniqueAddress(Address("pekko", "sys", "d", 7355), 4L)
+ val nodeE = UniqueAddress(Address("pekko", "sys", "e", 7355), 5L)
"Reachability table" must {
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerSpec.scala
index 6a810846bf..e5f8a7c377 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerSpec.scala
@@ -81,13 +81,13 @@ class ClusterMessageSerializerSpec extends PekkoSpec("pekko.actor.provider = clu
import MemberStatus._
val a1 =
- TestMember(Address("pekko", "sys", "a", 2552), Joining, Set.empty[String], appVersion = Version("1.0.0"))
- val b1 = TestMember(Address("pekko", "sys", "b", 2552), Up, Set("r1"), appVersion = Version("1.1.0"))
+ TestMember(Address("pekko", "sys", "a", 7355), Joining, Set.empty[String], appVersion = Version("1.0.0"))
+ val b1 = TestMember(Address("pekko", "sys", "b", 7355), Up, Set("r1"), appVersion = Version("1.1.0"))
val c1 =
- TestMember(Address("pekko", "sys", "c", 2552), Leaving, Set.empty[String], "foo", appVersion = Version("1.1.0"))
- val d1 = TestMember(Address("pekko", "sys", "d", 2552), Exiting, Set("r1"), "foo")
- val e1 = TestMember(Address("pekko", "sys", "e", 2552), Down, Set("r3"))
- val f1 = TestMember(Address("pekko", "sys", "f", 2552), Removed, Set("r3"), "foo")
+ TestMember(Address("pekko", "sys", "c", 7355), Leaving, Set.empty[String], "foo", appVersion = Version("1.1.0"))
+ val d1 = TestMember(Address("pekko", "sys", "d", 7355), Exiting, Set("r1"), "foo")
+ val e1 = TestMember(Address("pekko", "sys", "e", 7355), Down, Set("r3"))
+ val f1 = TestMember(Address("pekko", "sys", "f", 7355), Removed, Set("r3"), "foo")
"ClusterMessages" must {
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/sbr/TestAddresses.scala b/cluster/src/test/scala/org/apache/pekko/cluster/sbr/TestAddresses.scala
index 50110ab1ed..dc892a7c0a 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/sbr/TestAddresses.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/sbr/TestAddresses.scala
@@ -32,7 +32,7 @@ object TestAddresses {
val defaultDataCenter = ClusterSettings.DefaultDataCenter
private def defaultDcRole = dcRole(defaultDataCenter)
- val addressA = Address("pekko.tcp", "sys", "a", 2552)
+ val addressA = Address("pekko.tcp", "sys", "a", 7355)
val memberA = new Member(UniqueAddress(addressA, 0L), 5, Up, Set("role3", defaultDcRole), Version.Zero)
val memberB =
new Member(
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDownSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDownSpec.scala
index 3a604071fe..38f9331799 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDownSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDownSpec.scala
@@ -58,9 +58,9 @@ class AutoDownSpec extends PekkoSpec("""
if (RARP(system).provider.remoteSettings.Artery.Enabled) "pekko"
else "pekko.tcp"
- val memberA = TestMember(Address(protocol, "sys", "a", 2552), Up)
- val memberB = TestMember(Address(protocol, "sys", "b", 2552), Up)
- val memberC = TestMember(Address(protocol, "sys", "c", 2552), Up)
+ val memberA = TestMember(Address(protocol, "sys", "a", 7355), Up)
+ val memberB = TestMember(Address(protocol, "sys", "b", 7355), Up)
+ val memberC = TestMember(Address(protocol, "sys", "c", 7355), Up)
def autoDownActor(autoDownUnreachableAfter: FiniteDuration): ActorRef =
system.actorOf(Props(classOf[AutoDownTestActor], memberA, autoDownUnreachableAfter, testActor))
diff --git a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala
index 5eb7700567..d24e7b2aa7 100644
--- a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala
+++ b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala
@@ -175,7 +175,7 @@ class ReplicatorMessageSerializer(val system: ExtendedActorSystem)
}(system.dispatchers.internalDispatcher)
private val writeAckBytes = dm.Empty.getDefaultInstance.toByteArray
- private val dummyAddress = UniqueAddress(Address("a", "b", "c", 2552), 1L)
+ private val dummyAddress = UniqueAddress(Address("a", "b", "c", 7355), 1L)
val GetManifest = "A"
val GetSuccessManifest = "B"
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
index 0fa0fc878a..d25f8adbde 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
@@ -25,7 +25,7 @@ class DataEnvelopeSpec extends AnyWordSpec with Matchers {
import PruningState._
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
val obsoleteTimeInFuture = System.currentTimeMillis() + 3600 * 1000
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
index e9471d111c..2d7c90cfed 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class GCounterSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
"A GCounter" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
index 1079ca5a03..e13375382b 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
@@ -25,7 +25,7 @@ class LWWMapSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
index ea0d8076ba..df5465c757 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
@@ -25,7 +25,7 @@ class LWWRegisterSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWRegister" must {
"use latest of successive assignments" in {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
index 0df631d97f..bb830c5d67 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
@@ -33,7 +33,7 @@ object LotsOfDataBot {
def main(args: Array[String]): Unit = {
if (args.isEmpty)
- startup(Seq("2551", "2552", "0"))
+ startup(Seq("2551", "7355", "0"))
else
startup(args.toIndexedSeq)
}
@@ -58,7 +58,7 @@ object LotsOfDataBot {
pekko.cluster {
seed-nodes = [
"pekko://ClusterSystem@127.0.0.1:2551",
- "pekko://ClusterSystem@127.0.0.1:2552"]
+ "pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = org.apache.pekko.cluster.testkit.AutoDowning
testkit.auto-down-unreachable-after = 10s
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
index 2da1bb73c2..f2b1dd82f2 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
@@ -25,7 +25,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMapSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
index 2b6c2e1946..a469da028c 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMultiMapSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMultiMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
index 1496bec5ca..4d92b37107 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
@@ -26,10 +26,10 @@ import pekko.cluster.ddata.Replicator.Changed
class ORSetSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
- val nodeA = UniqueAddress(Address("pekko", "Sys", "a", 2552), 1L)
+ val nodeA = UniqueAddress(Address("pekko", "Sys", "a", 7355), 1L)
val nodeB = UniqueAddress(nodeA.address.copy(host = Some("b")), 2L)
val nodeC = UniqueAddress(nodeA.address.copy(host = Some("c")), 3L)
val nodeD = UniqueAddress(nodeA.address.copy(host = Some("d")), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
index 30ecbbdb2e..6e062dd0f0 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class PNCounterMapSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounterMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
index 66c83e60c0..0ef9d4f761 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class PNCounterSpec extends AnyWordSpec with Matchers {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounter" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
index 4b0d0f68d6..ef681c8dc0 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
@@ -24,7 +24,7 @@ class PruningStateSpec extends AnyWordSpec with Matchers {
import PruningState._
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
index 1d24037c77..6be8df509f 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
@@ -30,7 +30,7 @@ class VersionVectorSpec
with BeforeAndAfterAll {
val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
- val node2 = UniqueAddress(node1.address.copy(port = Some(2552)), 2L)
+ val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(2553)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(2554)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/WriteAggregatorSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/WriteAggregatorSpec.scala
index 8b16f22ee3..d1feb304e4 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/WriteAggregatorSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/WriteAggregatorSpec.scala
@@ -153,10 +153,10 @@ class WriteAggregatorSpec extends PekkoSpec(s"""
if (RARP(system).provider.remoteSettings.Artery.Enabled) "pekko"
else "pekko.tcp"
- val nodeA = UniqueAddress(Address(protocol, "Sys", "a", 2552), 17L)
- val nodeB = UniqueAddress(Address(protocol, "Sys", "b", 2552), 17L)
- val nodeC = UniqueAddress(Address(protocol, "Sys", "c", 2552), 17L)
- val nodeD = UniqueAddress(Address(protocol, "Sys", "d", 2552), 17L)
+ val nodeA = UniqueAddress(Address(protocol, "Sys", "a", 7355), 17L)
+ val nodeB = UniqueAddress(Address(protocol, "Sys", "b", 7355), 17L)
+ val nodeC = UniqueAddress(Address(protocol, "Sys", "c", 7355), 17L)
+ val nodeD = UniqueAddress(Address(protocol, "Sys", "d", 7355), 17L)
// 4 replicas + the local => 5
val nodes = Vector(nodeA, nodeB, nodeC, nodeD)
diff --git a/docs/src/main/paradox/cluster-usage.md b/docs/src/main/paradox/cluster-usage.md
index aaae8aca5b..c2cf319fb1 100644
--- a/docs/src/main/paradox/cluster-usage.md
+++ b/docs/src/main/paradox/cluster-usage.md
@@ -412,7 +412,7 @@ Where the <node-url> should be on the format of
'pekko.<protocol>://<actor-system-name>@<hostname>:<port>'
Examples: ./pekko-cluster localhost 9999 is-available
- ./pekko-cluster localhost 9999 join pekko://MySystem@darkstar:2552
+ ./pekko-cluster localhost 9999 join pekko://MySystem@darkstar:7355
./pekko-cluster localhost 9999 cluster-status
```
diff --git a/docs/src/main/paradox/remoting-artery.md b/docs/src/main/paradox/remoting-artery.md
index 6a87d1efb8..a10164c373 100644
--- a/docs/src/main/paradox/remoting-artery.md
+++ b/docs/src/main/paradox/remoting-artery.md
@@ -58,7 +58,7 @@ pekko {
artery {
transport = tcp # See Selecting a transport below
canonical.hostname = "127.0.0.1"
- canonical.port = 25520
+ canonical.port = 73550
}
}
}
@@ -189,13 +189,13 @@ In the next sections the two alternatives are described in detail.
Scala
: ```
val selection =
- context.actorSelection("pekko://actorSystemName@10.0.0.1:25520/user/actorName")
+ context.actorSelection("pekko://actorSystemName@10.0.0.1:73550/user/actorName")
```
Java
: ```
ActorSelection selection =
- context.actorSelection("pekko://actorSystemName@10.0.0.1:25520/user/actorName");
+ context.actorSelection("pekko://actorSystemName@10.0.0.1:73550/user/actorName");
```
@@ -850,7 +850,7 @@ pekko {
canonical.port = 8000 # external (logical) port
bind.hostname = local.address # internal (bind) hostname
- bind.port = 25520 # internal (bind) port
+ bind.port = 73550 # internal (bind) port
}
}
}
diff --git a/docs/src/main/paradox/remoting.md b/docs/src/main/paradox/remoting.md
index 827f6f3eed..edee72d236 100644
--- a/docs/src/main/paradox/remoting.md
+++ b/docs/src/main/paradox/remoting.md
@@ -60,7 +60,7 @@ pekko {
enabled-transports = ["pekko.remote.classic.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1"
- port = 2552
+ port = 7355
}
}
}
@@ -126,13 +126,13 @@ In the next sections the two alternatives are described in detail.
Scala
: ```
val selection =
- context.actorSelection("pekko.tcp://actorSystemName@10.0.0.1:2552/user/actorName")
+ context.actorSelection("pekko.tcp://actorSystemName@10.0.0.1:7355/user/actorName")
```
Java
: ```
ActorSelection selection =
- context.actorSelection("pekko.tcp://app@10.0.0.1:2552/user/serviceA/worker");
+ context.actorSelection("pekko.tcp://app@10.0.0.1:7355/user/serviceA/worker");
```
As you can see from the example above the following pattern is used to find an actor on a remote node:
@@ -609,7 +609,7 @@ pekko.remote.classic.netty.tcp {
port = 8000 # external (logical) port
bind-hostname = local.address # internal (bind) hostname
- bind-port = 2552 # internal (bind) port
+ bind-port = 7355 # internal (bind) port
}
```
diff --git a/docs/src/main/paradox/typed/cluster.md b/docs/src/main/paradox/typed/cluster.md
index 89265c4c16..7443f02d5b 100644
--- a/docs/src/main/paradox/typed/cluster.md
+++ b/docs/src/main/paradox/typed/cluster.md
@@ -155,15 +155,15 @@ You can define the seed nodes in the @ref:[configuration](#configuration) file (
```
pekko.cluster.seed-nodes = [
- "pekko://ClusterSystem@host1:2552",
- "pekko://ClusterSystem@host2:2552"]
+ "pekko://ClusterSystem@host1:7355",
+ "pekko://ClusterSystem@host2:7355"]
```
This can also be defined as Java system properties when starting the JVM using the following syntax:
```
--Dpekko.cluster.seed-nodes.0=pekko://ClusterSystem@host1:2552
--Dpekko.cluster.seed-nodes.1=pekko://ClusterSystem@host2:2552
+-Dpekko.cluster.seed-nodes.0=pekko://ClusterSystem@host1:7355
+-Dpekko.cluster.seed-nodes.1=pekko://ClusterSystem@host2:7355
```
diff --git a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
index 4b9d867ce2..07a05c6ed3 100644
--- a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
+++ b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
@@ -28,7 +28,7 @@ public class StatsSampleOneMasterMain {
public static void main(String[] args) {
if (args.length == 0) {
- startup(new String[] {"2551", "2552", "0"});
+ startup(new String[] {"2551", "7355", "0"});
StatsSampleOneMasterClientMain.main(new String[0]);
} else {
startup(args);
diff --git a/docs/src/test/java/jdocs/persistence/LambdaPersistencePluginDocTest.java b/docs/src/test/java/jdocs/persistence/LambdaPersistencePluginDocTest.java
index 8399566601..72b76c1b2b 100644
--- a/docs/src/test/java/jdocs/persistence/LambdaPersistencePluginDocTest.java
+++ b/docs/src/test/java/jdocs/persistence/LambdaPersistencePluginDocTest.java
@@ -53,7 +53,7 @@ public class LambdaPersistencePluginDocTest {
class SharedStorageUsage extends AbstractActor {
@Override
public void preStart() throws Exception {
- String path = "pekko://example@127.0.0.1:2552/user/store";
+ String path = "pekko://example@127.0.0.1:7355/user/store";
ActorSelection selection = getContext().actorSelection(path);
selection.tell(new Identify(1), getSelf());
}
diff --git a/docs/src/test/scala/docs/persistence/PersistencePluginDocSpec.scala b/docs/src/test/scala/docs/persistence/PersistencePluginDocSpec.scala
index 9b0d33304f..f9a6ea2cba 100644
--- a/docs/src/test/scala/docs/persistence/PersistencePluginDocSpec.scala
+++ b/docs/src/test/scala/docs/persistence/PersistencePluginDocSpec.scala
@@ -138,7 +138,7 @@ object SharedLeveldbPluginDocSpec {
// #shared-store-usage
trait SharedStoreUsage extends Actor {
override def preStart(): Unit = {
- context.actorSelection("pekko://example@127.0.0.1:2552/user/store") ! Identify(1)
+ context.actorSelection("pekko://example@127.0.0.1:7355/user/store") ! Identify(1)
}
def receive = {
diff --git a/docs/src/test/scala/docs/routing/RouterDocSpec.scala b/docs/src/test/scala/docs/routing/RouterDocSpec.scala
index 320f04d2cd..ed95d737a2 100644
--- a/docs/src/test/scala/docs/routing/RouterDocSpec.scala
+++ b/docs/src/test/scala/docs/routing/RouterDocSpec.scala
@@ -219,7 +219,7 @@ pekko.actor.deployment {
/parent/remotePool {
router = round-robin-pool
nr-of-instances = 10
- target.nodes = ["pekko://app@10.0.0.2:2552", "pekko://app@10.0.0.3:2552"]
+ target.nodes = ["pekko://app@10.0.0.2:7355", "pekko://app@10.0.0.3:7355"]
}
}
#//#config-remote-round-robin-pool
@@ -229,7 +229,7 @@ pekko.actor.deployment {
/parent/remotePool {
router = round-robin-pool
nr-of-instances = 10
- target.nodes = ["tcp://app@10.0.0.2:2552", "pekko://app@10.0.0.3:2552"]
+ target.nodes = ["tcp://app@10.0.0.2:7355", "pekko://app@10.0.0.3:7355"]
}
}
#//#config-remote-round-robin-pool-artery
@@ -239,9 +239,9 @@ pekko.actor.deployment {
/parent/remoteGroup {
router = round-robin-group
routees.paths = [
- "pekko://app@10.0.0.1:2552/user/workers/w1",
- "pekko://app@10.0.0.2:2552/user/workers/w1",
- "pekko://app@10.0.0.3:2552/user/workers/w1"]
+ "pekko://app@10.0.0.1:7355/user/workers/w1",
+ "pekko://app@10.0.0.2:7355/user/workers/w1",
+ "pekko://app@10.0.0.3:7355/user/workers/w1"]
}
}
#//#config-remote-round-robin-group
@@ -251,9 +251,9 @@ pekko.actor.deployment {
/parent/remoteGroup2 {
router = round-robin-group
routees.paths = [
- "pekko://app@10.0.0.1:2552/user/workers/w1",
- "pekko://app@10.0.0.2:2552/user/workers/w1",
- "pekko://app@10.0.0.3:2552/user/workers/w1"]
+ "pekko://app@10.0.0.1:7355/user/workers/w1",
+ "pekko://app@10.0.0.2:7355/user/workers/w1",
+ "pekko://app@10.0.0.3:7355/user/workers/w1"]
}
}
#//#config-remote-round-robin-group-artery
diff --git a/remote/src/main/resources/reference.conf b/remote/src/main/resources/reference.conf
index 1aec87aee8..8e761ffa13 100644
--- a/remote/src/main/resources/reference.conf
+++ b/remote/src/main/resources/reference.conf
@@ -499,9 +499,9 @@ pekko {
applied-adapters = []
# The default remote server port clients should connect to.
- # Default is 2552 (AKKA), use 0 if you want a random available port
+ # Default is 7355 (AKKA), use 0 if you want a random available port
# This port needs to be unique for each actor system on the same machine.
- port = 2552
+ port = 7355
# The hostname or ip clients should connect to.
# InetAddress.getLocalHost.getHostAddress is used if empty
@@ -512,29 +512,29 @@ pekko {
# when running pekko nodes in a separated networks (under NATs or docker containers).
# Use 0 if you want a random available port. Examples:
#
- # pekko.remote.classic.netty.tcp.port = 2552
+ # pekko.remote.classic.netty.tcp.port = 7355
# pekko.remote.classic.netty.tcp.bind-port = 2553
# Network interface will be bound to the 2553 port, but remoting protocol will
- # expect messages sent to port 2552.
+ # expect messages sent to port 7355.
#
# pekko.remote.classic.netty.tcp.port = 0
# pekko.remote.classic.netty.tcp.bind-port = 0
# Network interface will be bound to a random port, and remoting protocol will
# expect messages sent to the bound port.
#
- # pekko.remote.classic.netty.tcp.port = 2552
+ # pekko.remote.classic.netty.tcp.port = 7355
# pekko.remote.classic.netty.tcp.bind-port = 0
# Network interface will be bound to a random port, but remoting protocol will
- # expect messages sent to port 2552.
+ # expect messages sent to port 7355.
#
# pekko.remote.classic.netty.tcp.port = 0
# pekko.remote.classic.netty.tcp.bind-port = 2553
# Network interface will be bound to the 2553 port, and remoting protocol will
# expect messages sent to the bound port.
#
- # pekko.remote.classic.netty.tcp.port = 2552
+ # pekko.remote.classic.netty.tcp.port = 7355
# pekko.remote.classic.netty.tcp.bind-port = ""
- # Network interface will be bound to the 2552 port, and remoting protocol will
+ # Network interface will be bound to the 7355 port, and remoting protocol will
# expect messages sent to the bound port.
#
# pekko.remote.classic.netty.tcp.port if empty
@@ -760,9 +760,9 @@ pekko {
canonical {
# The default remote server port clients should connect to.
- # Default is 25520, use 0 if you want a random available port
+ # Default is 73550, use 0 if you want a random available port
# This port needs to be unique for each actor system on the same machine.
- port = 25520
+ port = 73550
# Hostname clients should connect to. Can be set to an ip, hostname
# or one of the following special values:
diff --git a/remote/src/test/scala/org/apache/pekko/remote/RemoteConsistentHashingRouterSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/RemoteConsistentHashingRouterSpec.scala
index 51d76ecf96..99ea604d5a 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/RemoteConsistentHashingRouterSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/RemoteConsistentHashingRouterSpec.scala
@@ -29,11 +29,11 @@ class RemoteConsistentHashingRouterSpec
"use same hash ring independent of self address" in {
// simulating running router on two different nodes (a1, a2) with target routees on 3 other nodes (s1, s2, s3)
- val a1 = Address("pekko", "Sys", "client1", 2552)
- val a2 = Address("pekko", "Sys", "client2", 2552)
- val s1 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server1:2552/user/a/b"))
- val s2 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server2:2552/user/a/b"))
- val s3 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server3:2552/user/a/b"))
+ val a1 = Address("pekko", "Sys", "client1", 7355)
+ val a2 = Address("pekko", "Sys", "client2", 7355)
+ val s1 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server1:7355/user/a/b"))
+ val s2 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server2:7355/user/a/b"))
+ val s3 = ActorSelectionRoutee(system.actorSelection("pekko://Sys@server3:7355/user/a/b"))
val nodes1 = List(ConsistentRoutee(s1, a1), ConsistentRoutee(s2, a1), ConsistentRoutee(s3, a1))
val nodes2 = List(ConsistentRoutee(s1, a2), ConsistentRoutee(s2, a2), ConsistentRoutee(s3, a2))
val consistentHash1 = ConsistentHash(nodes1, 10)
diff --git a/remote/src/test/scala/org/apache/pekko/remote/RemoteDeployerSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/RemoteDeployerSpec.scala
index 0dd517aad2..3f896cc388 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/RemoteDeployerSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/RemoteDeployerSpec.scala
@@ -29,7 +29,7 @@ object RemoteDeployerSpec {
/service2 {
router = round-robin-pool
nr-of-instances = 3
- remote = "pekko://sys@wallace:2552"
+ remote = "pekko://sys@wallace:7355"
dispatcher = mydispatcher
}
}
@@ -57,7 +57,7 @@ class RemoteDeployerSpec extends PekkoSpec(RemoteDeployerSpec.deployerConf) {
service,
deployment.get.config,
RoundRobinPool(3),
- RemoteScope(Address("pekko", "sys", "wallace", 2552)),
+ RemoteScope(Address("pekko", "sys", "wallace", 7355)),
"mydispatcher")))
}
diff --git a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeathWatchSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeathWatchSpec.scala
index ada682253a..d77b549e97 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeathWatchSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeathWatchSpec.scala
@@ -94,7 +94,7 @@ class RemoteDeathWatchSpec
}
"receive Terminated when watched node is unknown host" in {
- val path = RootActorPath(Address("pekko", system.name, "unknownhost", 2552)) / "user" / "subject"
+ val path = RootActorPath(Address("pekko", system.name, "unknownhost", 7355)) / "user" / "subject"
system.actorOf(Props(new Actor {
@nowarn
@@ -114,7 +114,7 @@ class RemoteDeathWatchSpec
// immediately in constructor from aeron.addPublication when UnknownHostException. That will trigger
// this immediately. With TCP it will trigger after handshake timeout. Can we see the UnknownHostException
// reason somehow and fail the stream immediately for that case?
- val path = RootActorPath(Address("pekko", system.name, "unknownhost2", 2552)) / "user" / "subject"
+ val path = RootActorPath(Address("pekko", system.name, "unknownhost2", 7355)) / "user" / "subject"
system.actorSelection(path) ! Identify(path.toString)
expectMsg(60.seconds, ActorIdentity(path.toString, None))
}
diff --git a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeployerSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeployerSpec.scala
index 406df034c9..c76bd1381f 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeployerSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeployerSpec.scala
@@ -28,7 +28,7 @@ object RemoteDeployerSpec {
/service2 {
router = round-robin-pool
nr-of-instances = 3
- remote = "pekko://sys@wallace:2552"
+ remote = "pekko://sys@wallace:7355"
dispatcher = mydispatcher
}
}
@@ -54,7 +54,7 @@ class RemoteDeployerSpec extends PekkoSpec(RemoteDeployerSpec.deployerConf) {
service,
deployment.get.config,
RoundRobinPool(3),
- RemoteScope(Address("pekko", "sys", "wallace", 2552)),
+ RemoteScope(Address("pekko", "sys", "wallace", 7355)),
"mydispatcher")))
}
diff --git a/remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeathWatchSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeathWatchSpec.scala
index 192db6b9d3..47183caa49 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeathWatchSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeathWatchSpec.scala
@@ -101,7 +101,7 @@ pekko.actor.warn-about-java-serializer-usage = off
}
"receive Terminated when watched node is unknown host" in {
- val path = RootActorPath(Address(protocol, system.name, "unknownhost", 2552)) / "user" / "subject"
+ val path = RootActorPath(Address(protocol, system.name, "unknownhost", 7355)) / "user" / "subject"
system.actorOf(Props(new Actor {
@nowarn
@@ -117,7 +117,7 @@ pekko.actor.warn-about-java-serializer-usage = off
}
"receive ActorIdentity(None) when identified node is unknown host" in {
- val path = RootActorPath(Address(protocol, system.name, "unknownhost2", 2552)) / "user" / "subject"
+ val path = RootActorPath(Address(protocol, system.name, "unknownhost2", 7355)) / "user" / "subject"
system.actorSelection(path) ! Identify(path)
expectMsg(60.seconds, ActorIdentity(path, None))
}
diff --git a/serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JacksonSerializerSpec.scala b/serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JacksonSerializerSpec.scala
index 5f97c97c1f..5cb17973a8 100644
--- a/serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JacksonSerializerSpec.scala
+++ b/serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JacksonSerializerSpec.scala
@@ -856,7 +856,7 @@ abstract class JacksonSerializerSpec(serializerName: String)
}
"serialize with Address" in {
- val address = Address("pekko", "sys", "localhost", 2552)
+ val address = Address("pekko", "sys", "localhost", 7355)
checkSerialization(new CommandWithAddress("echo", address))
}
@@ -1082,7 +1082,7 @@ abstract class JacksonSerializerSpec(serializerName: String)
}
"serialize with Address" in {
- val address = Address("pekko", "sys", "localhost", 2552)
+ val address = Address("pekko", "sys", "localhost", 7355)
checkSerialization(CommandWithAddress("echo", address))
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko] 03/05: artery port = 17355
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit c23f9fb83468fa1041d003c904442fb2fd34a931
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Tue Mar 7 01:54:53 2023 +0100
artery port = 17355
---
docs/src/main/paradox/remoting-artery.md | 8 ++++----
remote/src/main/resources/reference.conf | 4 ++--
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/docs/src/main/paradox/remoting-artery.md b/docs/src/main/paradox/remoting-artery.md
index a10164c373..82dce3de27 100644
--- a/docs/src/main/paradox/remoting-artery.md
+++ b/docs/src/main/paradox/remoting-artery.md
@@ -58,7 +58,7 @@ pekko {
artery {
transport = tcp # See Selecting a transport below
canonical.hostname = "127.0.0.1"
- canonical.port = 73550
+ canonical.port = 17355
}
}
}
@@ -189,13 +189,13 @@ In the next sections the two alternatives are described in detail.
Scala
: ```
val selection =
- context.actorSelection("pekko://actorSystemName@10.0.0.1:73550/user/actorName")
+ context.actorSelection("pekko://actorSystemName@10.0.0.1:17355/user/actorName")
```
Java
: ```
ActorSelection selection =
- context.actorSelection("pekko://actorSystemName@10.0.0.1:73550/user/actorName");
+ context.actorSelection("pekko://actorSystemName@10.0.0.1:17355/user/actorName");
```
@@ -850,7 +850,7 @@ pekko {
canonical.port = 8000 # external (logical) port
bind.hostname = local.address # internal (bind) hostname
- bind.port = 73550 # internal (bind) port
+ bind.port = 17355 # internal (bind) port
}
}
}
diff --git a/remote/src/main/resources/reference.conf b/remote/src/main/resources/reference.conf
index 4f03796b62..3705bf1725 100644
--- a/remote/src/main/resources/reference.conf
+++ b/remote/src/main/resources/reference.conf
@@ -760,9 +760,9 @@ pekko {
canonical {
# The default remote server port clients should connect to.
- # Default is 73550, use 0 if you want a random available port
+ # Default is 17355, use 0 if you want a random available port
# This port needs to be unique for each actor system on the same machine.
- port = 73550
+ port = 17355
# Hostname clients should connect to. Can be set to an ip, hostname
# or one of the following special values:
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko] 04/05: replace 2551 with 7354
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit 5322174ecc57cbf7ab0d2babe219d1e4f7b2b7c5
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Mar 8 11:40:04 2023 +0100
replace 2551 with 7354
---
.../apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala | 8 ++++----
.../org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala | 8 ++++----
.../org/apache/pekko/cluster/typed/BasicClusterExampleTest.java | 4 ++--
.../org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala | 8 ++++----
cluster/jmx-client/pekko-cluster | 6 +++---
.../apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala | 4 ++--
.../src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala | 2 +-
.../src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala | 2 +-
docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java | 2 +-
19 files changed, 32 insertions(+), 32 deletions(-)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
index 29547b593f..5546d14c62 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
@@ -28,10 +28,10 @@ class MetricsSelectorSpec extends AnyWordSpec with Matchers {
override def capacity(nodeMetrics: Set[NodeMetrics]): Map[Address, Double] = Map.empty
}
- val a1 = Address("pekko", "sys", "a1", 2551)
- val b1 = Address("pekko", "sys", "b1", 2551)
- val c1 = Address("pekko", "sys", "c1", 2551)
- val d1 = Address("pekko", "sys", "d1", 2551)
+ val a1 = Address("pekko", "sys", "a1", 7354)
+ val b1 = Address("pekko", "sys", "b1", 7354)
+ val c1 = Address("pekko", "sys", "c1", 7354)
+ val d1 = Address("pekko", "sys", "d1", 7354)
val decayFactor = Some(0.18)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
index ccf8b40f88..8f92164152 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
@@ -35,10 +35,10 @@ class WeightedRouteesSpec extends PekkoSpec(ConfigFactory.parseString("""
if (RARP(system).provider.remoteSettings.Artery.Enabled) "pekko"
else "pekko.tcp"
- val a1 = Address(protocol, "sys", "a1", 2551)
- val b1 = Address(protocol, "sys", "b1", 2551)
- val c1 = Address(protocol, "sys", "c1", 2551)
- val d1 = Address(protocol, "sys", "d1", 2551)
+ val a1 = Address(protocol, "sys", "a1", 7354)
+ val b1 = Address(protocol, "sys", "b1", 7354)
+ val c1 = Address(protocol, "sys", "c1", 7354)
+ val d1 = Address(protocol, "sys", "d1", 7354)
val routeeA = ActorSelectionRoutee(system.actorSelection(RootActorPath(a1) / "user" / "a"))
val routeeB = ActorSelectionRoutee(system.actorSelection(RootActorPath(b1) / "user" / "b"))
diff --git a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
index b92d3d01e2..fe5445af20 100644
--- a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
+++ b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
@@ -45,7 +45,7 @@ public class BasicClusterExampleTest { // extends JUnitSuite {
+ " remote.artery { \n"
+ " canonical { \n"
+ " hostname = \"127.0.0.1\" \n"
- + " port = 2551 \n"
+ + " port = 7354 \n"
+ " } \n"
+ " } \n"
+ "} \n");
@@ -131,7 +131,7 @@ public class BasicClusterExampleTest { // extends JUnitSuite {
// #join-seed-nodes
List<Address> seedNodes = new ArrayList<>();
- seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:2551"));
+ seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:7354"));
seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:7355"));
Cluster.get(system).manager().tell(new JoinSeedNodes(seedNodes));
diff --git a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
index 6e3a4a13e8..5e9dda4298 100644
--- a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
+++ b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
@@ -46,13 +46,13 @@ pekko {
remote.artery {
canonical {
hostname = "127.0.0.1"
- port = 2551
+ port = 7354
}
}
cluster {
seed-nodes = [
- "pekko://ClusterSystem@127.0.0.1:2551",
+ "pekko://ClusterSystem@127.0.0.1:7354",
"pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = "org.apache.pekko.cluster.sbr.SplitBrainResolverProvider"
@@ -75,7 +75,7 @@ pekko {
import pekko.cluster.typed.JoinSeedNodes
val seedNodes: List[Address] =
- List("pekko://ClusterSystem@127.0.0.1:2551", "pekko://ClusterSystem@127.0.0.1:7355").map(
+ List("pekko://ClusterSystem@127.0.0.1:7354", "pekko://ClusterSystem@127.0.0.1:7355").map(
AddressFromURIString.parse)
Cluster(system).manager ! JoinSeedNodes(seedNodes)
// #join-seed-nodes
@@ -163,7 +163,7 @@ pekko {
remote.artery {
canonical {
hostname = "127.0.0.1"
- port = 2551
+ port = 7354
}
}
}
diff --git a/cluster/jmx-client/pekko-cluster b/cluster/jmx-client/pekko-cluster
index 2bb59b63a4..ac347238fc 100755
--- a/cluster/jmx-client/pekko-cluster
+++ b/cluster/jmx-client/pekko-cluster
@@ -219,9 +219,9 @@ do
printf "Examples: $0 localhost 9999 is-available\n"
printf " $0 localhost 9999 join pekko.tcp://MySystem@darkstar:7355\n"
printf " $0 localhost 9999 cluster-status\n"
- printf " $0 localhost 9999 -p 2551 is-available\n"
- printf " $0 localhost 9999 -p 2551 join pekko.tcp://MySystem@darkstar:7355\n"
- printf " $0 localhost 9999 -p 2551 cluster-status\n"
+ printf " $0 localhost 9999 -p 7354 is-available\n"
+ printf " $0 localhost 9999 -p 7354 join pekko.tcp://MySystem@darkstar:7355\n"
+ printf " $0 localhost 9999 -p 7354 cluster-status\n"
exit 1
;;
esac
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
index 3df03b3147..e2c828ad78 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
@@ -61,7 +61,7 @@ class ClusterDomainEventPublisherSpec
val cJoining = TestMember(Address(protocol, "sys", "c", 7355), Joining, Set("GRP"))
val cUp = cJoining.copy(status = Up)
val cRemoved = cUp.copy(status = Removed)
- val a51Up = TestMember(Address(protocol, "sys", "a", 2551), Up)
+ val a51Up = TestMember(Address(protocol, "sys", "a", 7354), Up)
val dUp = TestMember(Address(protocol, "sys", "d", 7355), Up, Set("GRP"))
val eUp = TestMember(Address(protocol, "sys", "e", 7355), Up, Set("GRP"), OtherDataCenter)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
index c48c080db8..29cf0ac607 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Internal.DataEnvelope
class DataEnvelopeSpec extends AnyWordSpec with Matchers {
import PruningState._
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
index d04649f707..51178dfe7f 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
@@ -22,7 +22,7 @@ import pekko.cluster.UniqueAddress
import pekko.cluster.ddata.Replicator.Changed
class GCounterSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
index e13375382b..e4f326968d 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class LWWMapSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
index df5465c757..864655d026 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class LWWRegisterSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWRegister" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
index bb830c5d67..c8b2b7136b 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
@@ -33,7 +33,7 @@ object LotsOfDataBot {
def main(args: Array[String]): Unit = {
if (args.isEmpty)
- startup(Seq("2551", "7355", "0"))
+ startup(Seq("7354", "7355", "0"))
else
startup(args.toIndexedSeq)
}
@@ -57,7 +57,7 @@ object LotsOfDataBot {
pekko.cluster {
seed-nodes = [
- "pekko://ClusterSystem@127.0.0.1:2551",
+ "pekko://ClusterSystem@127.0.0.1:7354",
"pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = org.apache.pekko.cluster.testkit.AutoDowning
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
index f2b1dd82f2..f40e9a16d0 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
index a469da028c..15653f7f67 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMultiMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMultiMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
index f8a1cee29d..b04164324c 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
@@ -25,7 +25,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORSetSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
index 6e062dd0f0..3f8468db86 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class PNCounterMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounterMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
index 0ef9d4f761..7990808c51 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
@@ -22,7 +22,7 @@ import pekko.cluster.UniqueAddress
import pekko.cluster.ddata.Replicator.Changed
class PNCounterSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounter" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
index 24ab7c978b..d6f3c7cc69 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.UniqueAddress
class PruningStateSpec extends AnyWordSpec with Matchers {
import PruningState._
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
index ff65f934b4..b1a3d2c07a 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
@@ -29,7 +29,7 @@ class VersionVectorSpec
with Matchers
with BeforeAndAfterAll {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
index 07a05c6ed3..162a4784df 100644
--- a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
+++ b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
@@ -28,7 +28,7 @@ public class StatsSampleOneMasterMain {
public static void main(String[] args) {
if (args.length == 0) {
- startup(new String[] {"2551", "7355", "0"});
+ startup(new String[] {"7354", "7355", "0"});
StatsSampleOneMasterClientMain.main(new String[0]);
} else {
startup(args);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org