akka/akka-core

Unstashed messages enqueued in TestActorRef mailbox while processing a message from self are stuck until another message is received

Open

#30 170 ouverte le 7 avr. 2021

Voir sur GitHub
 (1 commentaire) (0 réactions) (0 assignés)Scala (3 547 forks)batch import
help wantednice-to-have (low-prio)t:testing

Métriques du dépôt

Stars
 (13 277 stars)
Métriques de merge PR
 (Merge moyen 17h 35m) (11 PRs mergées en 30 j)

Description

In the following workflow, unstashed messages are enqueued in the mailbox but are not processed as expected:

  1. Send message (messageOne) from TestKit to TestActorRef
  2. TestActorRef underlying actor stashes messageOne and schedules a subsequent message to self (selfMessage)
  3. selfMessage is sent and processed and messageOne is unstashed during processing of selfMessage
  4. messageOne is not processed
  5. Send another message (messageTwo) from TestKit to TestActorRef
  6. Both messageOne and messageTwo are processed

akka.testkit.CallingThreadDispatcher#runQueue appears to process the provided MessageQueue at the time of invocation rather than using the active Mailbox MessageQueue.

Guide contributeur

Direction de recherche
Étudiez l'implémentation de la méthode CallingThreadDispatcher.runQueue et son interaction avec la MessageQueue de la Mailbox. Le problème suggère que runQueue traite la MessageQueue fournie au lieu de celle active. Comparez avec le comportement attendu et vérifiez s'il y a des modifications connexes dans la base de code. Considérez l'examen du mécanisme de stashing et comment les messages sont unstashed pendant le traitement des messages self.
Stack technique
scala
Domaine
backendtesting
Type d'issue
Bug
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
4
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
3-5 jours
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Ancienne
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Plutôt claire
Prérequis
Akka fundamentalsUnderstanding of actor mailboxKnowledge of CallingThreadDispatcher
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
20