Rather than having a separate Topology with delay, I was thinking that you could implement the delay in the EntranceProcessor (e.g., PrequentialSourceProcessor). This way it could be reusable across several topologies.