protected Pipeline pipeline;
public void run() {
int result = counter % 3;
if (result == 0) {
pipeline.process(new PipelineMessage("Message " + counter));
} else if (result == 1) {
registry.handle(new StringMessage("Test " + counter));
} else {
registry.handle(new IntMessage(counter));
}