The initial pass has no notion of a setup call, to avoid dead letters if the source actor comes up first and starts firing messages(think testing). there is a sleep. It really needs to be configured/kicked once we believe the cluster is setup -- or indeed its consumers could call in to request data