<dependency> <groupId>com.trickle</groupId> <artifactId>trickle-core</artifactId> <version>1.0.0</version> </dependency> public class MyProcessor extends Processor { @Override public void process(Data data) { } } Stream stream = new Stream(); stream.addProcessor(new MyProcessor()); stream.start();