}, "central broker");
cbt.start();
Chronicle chronicle3 = new IndexedChronicle(basePath3);
InProcessChronicleSource source3 = new InProcessChronicleSource(chronicle3, PORT3);
source3.busyWaitTimeNS(2 * 1000 * 1000);
EventsWriter writer3 = new EventsWriter(source3);
Chronicle chronicle2r = new IndexedChronicle(basePath2);
final EventsReader reader2 = new EventsReader(chronicle2r.createExcerpt(),
new BrokerEvents(writer3), TimingStage.EngineRead, TimingStage.SinkWrite);