ADR-24 CP6: Rails stream consumer worker