Evidently this is somewhat of a problem in testing: Some messages have not been consumed, or some messages have DLQed unexpectedly (wrt. the test).
Some kind of tool that allows for introspection of this. Problem: enumeration of queues. Possible solution: Instrument MatsFactory to note any consumers (StageProcessors) and Initiations.
Evidently this is somewhat of a problem in testing: Some messages have not been consumed, or some messages have DLQed unexpectedly (wrt. the test).
Some kind of tool that allows for introspection of this. Problem: enumeration of queues. Possible solution: Instrument MatsFactory to note any consumers (StageProcessors) and Initiations.