Så jeg tager hovedet, så begynder jeg at behandle. Problem, hvis dette skal skaleres og bruge en 8-tråds eksekveringstjeneste pr. pod/instans, ved pludselig nedlukning af systemet, ville "beskederne" allerede være blevet anset for taget/forbrugt.
Du skal bruge RStream-objekt i stedet, det tillader at spore uforbrugte elementer pr. forbruger.