import io.detective.core.*; import io.detective.core.pipeline.*; import io.detective.core.pipeline.message.*; DetectivePipeline pipeline = new DetectivePipeline(); pipeline.setDataSource(new MyDataSource()); pipeline.setFilter(new MyFilter()); pipeline.setTransformer(new MyTransformer()); pipeline.setHandler(new MyHandler()); Message message = new Message("Some input data"); pipeline.processMessage(message);