raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

ReliableDeliveryShardingSpec: double unconfirmed redelivery diagnosis (#31171)

Browse source 
To narrow down #30664
This commit is contained in:
Arnout Engelen 2022-02-22 16:39:21 +01:00 • committed by GitHub
parent a4d04075b8
commit f8a8654bb1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
View file

@ -29,10 +29,11 @@ import akka.cluster.sharding.typed.scaladsl.Entity
import akka.cluster.sharding.typed.scaladsl.EntityTypeKey
import akka.cluster.typed.Cluster
import akka.cluster.typed.Join
import akka.testkit.GHExcludeTest
object ReliableDeliveryShardingSpec {
val config = ConfigFactory.parseString("""
// temporary on debug to diagnose https://github.com/akka/akka/issues/30664
akka.loglevel = debug
akka.actor.provider = cluster
akka.remote.classic.netty.tcp.port = 0
akka.remote.artery.canonical.port = 0
@ -336,8 +337,10 @@ class ReliableDeliveryShardingSpec
testKit.stop(shardingProducerController)
}
// FIXME issue https://github.com/akka/akka/issues/30567
"deliver unconfirmed if ShardingConsumerController is terminated" taggedAs GHExcludeTest in {
// This test sometimes files on GitHub Actions (https://github.com/akka/akka/issues/30664),
// which might be a real issue.
// It seems msg-3, which is 'correctly' redelivered once, is sometimes redelivered twice.
"deliver unconfirmed if ShardingConsumerController is terminated" in {
// for example if ShardingConsumerController is rebalanced, but no more messages are sent to the entity
nextId()