Takže vezmu Head a začnu zpracovávat. Problém, pokud to má být škálováno a pomocí 8vláknové spouštěcí služby na pod/instanci, při náhlém vypnutí systému by „zprávy“ byly považovány za již přijaté/spotřebované.
Místo toho musíte použít objekt RStream, který umožňuje sledovat nespotřebované prvky na spotřebitele.