InputPipe inputPipe = new InputPipe(); Processor processor1 = new DataConverter(); Processor processor2 = new DataValidator(); OutputPipe outputPipe = new OutputPipe(); inputPipe.addProcessor(processor1); inputPipe.addProcessor(processor2); processor1.setInputPipe(inputPipe); processor2.setInputPipe(inputPipe); processor2.setOutputPipe(outputPipe); inputPipe.processData(data);