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

Harden ConsumerControllerSpec, #30430 (#30655)

Browse source
This commit is contained in:
Patrik Nordwall 2021-09-08 10:23:22 +02:00 • committed by GitHub
parent a502e3db0d
commit 511ecff930
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-actor-typed-tests/src/test/scala/akka/actor/typed/delivery/ConsumerControllerSpec.scala
View file

@ -14,7 +14,6 @@ import akka.actor.typed.delivery.ConsumerController.DeliverThenStop
import akka.actor.typed.delivery.internal.ConsumerControllerImpl
import akka.actor.typed.delivery.internal.ProducerControllerImpl
import akka.serialization.SerializationExtension
import akka.testkit.GHExcludeTest
class ConsumerControllerSpec
extends ScalaTestWithActorTestKit(ConfigFactory.parseString("""
@ -473,8 +472,7 @@ class ConsumerControllerSpec
testKit.stop(consumerController)
}
// Excluded fo GHActions. See https://github.com/akka/akka/issues/30430
"send Ack when stopped" taggedAs GHExcludeTest in {
"send Ack when stopped" in {
nextId()
val consumerController =
spawn(ConsumerController[TestConsumer.Job](), s"consumerController-${idCount}")
@ -495,6 +493,11 @@ class ConsumerControllerSpec
consumerProbe1.expectMessageType[ConsumerController.Delivery[TestConsumer.Job]]
consumerController ! ConsumerController.Confirmed
consumerController ! sequencedMessage(producerId, 3, producerControllerProbe.ref)
consumerProbe1.expectMessageType[ConsumerController.Delivery[TestConsumer.Job]]
// now we know that the ConsumerController has received Confirmed for 2,
// and 3 is still not confirmed
testKit.stop(consumerController)
producerControllerProbe.expectMessage(ProducerControllerImpl.Ack(2L))
}