Use just one subscriber and delegate the work to the consumer actors.