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
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);