Skip to content

Commit

Permalink
Update MixedProtocolClusterSpec.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
pjfanning committed Dec 30, 2024
1 parent 3fe0646 commit a5d7ab6
Showing 1 changed file with 3 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ object MixedProtocolClusterSpec {
pekko.coordinated-shutdown.terminate-actor-system = on
pekko.remote.artery.canonical.port = 0
pekko.remote.classic.netty.tcp.port = 0
pekko.remote.artery.advanced.aeron.idle-cpu-level = 3
pekko.remote.accept-protocol-names = ["pekko", "akka"]
Expand All @@ -51,27 +52,21 @@ object MixedProtocolClusterSpec {
pekko.remote.protocol-name = "akka"
""").withFallback(configWithUdp)

val configWithTcp: Config =
ConfigFactory.parseString("""
pekko.remote.artery.canonical.port = 0
""").withFallback(baseConfig)

val configWithPekkoTcp: Config =
ConfigFactory.parseString("""
pekko.remote.protocol-name = "pekko"
""").withFallback(configWithTcp)
""").withFallback(baseConfig)

val configWithAkkaTcp: Config =
ConfigFactory.parseString("""
pekko.remote.protocol-name = "akka"
""").withFallback(configWithTcp)
""").withFallback(baseConfig)

val configWithNetty: Config =
ConfigFactory.parseString("""
pekko.remote.artery.enabled = false
pekko.remote.classic {
enabled-transports = ["pekko.remote.classic.netty.tcp"]
netty.tcp.port = 0
}
""").withFallback(baseConfig)

Expand Down

0 comments on commit a5d7ab6

Please sign in to comment.