Uma ideia é enviar os dados para uma lista (LPUSH) e cortá-los (LTRIM), para que não cresçam para sempre se não houver consumidores. Por outro lado, o consumidor pegaria itens dessa lista e os processaria. Você também pode usar notificações de keyspace e ser alertado sempre que um item for adicionado a essa fila.