Pipe[] pipes = new Pipe[]{ rawRequestPipe};
PipeConfig<ReleaseSchema> ackConfig = new PipeConfig<ReleaseSchema>(ReleaseSchema.instance);
Pipe<ReleaseSchema> ack = new Pipe<ReleaseSchema>(ackConfig );
PipeCleanerStage<ReleaseSchema> cleaner = new PipeCleanerStage<ReleaseSchema>(gm, ack);
PronghornStage stage = ClientHTTPRequestDataGeneratorStage.newInstance(gm, rawRequestPipe, iterations, paths);
<BUG>HTTP1xRouterStage stage2 = buildRouterStage(gm, apps, appPipeConfig, pipes, ack);
</BUG>
runGraph(gm, apps, iterations, stage2);
}
private void runGraph(GraphManager gm, final int apps, final int iterations, PronghornStage stage) {

Pipe[] pipes = new Pipe[]{ rawRequestPipe};
PipeConfig<ReleaseSchema> ackConfig = new PipeConfig<ReleaseSchema>(ReleaseSchema.instance);
Pipe<ReleaseSchema> ack = new Pipe<ReleaseSchema>(ackConfig );
PipeCleanerStage<ReleaseSchema> cleaner = new PipeCleanerStage<ReleaseSchema>(gm, ack);
PronghornStage stage = ClientHTTPRequestDataGeneratorStage.newInstance(gm, rawRequestPipe, iterations, paths);
HTTP1xRouterStage stage2 = buildRouterStage(gm, apps, appPipeConfig, pipes, ack, routerConfig);
runGraph(gm, apps, iterations, stage2);
}
private void runGraph(GraphManager gm, final int apps, final int iterations, PronghornStage stage) {
