001 package biz.hammurapi.dataflow; 002 003 004 public class ChainingMixer extends AbstractMixer { 005 006 private String name; 007 private JoinPredicate predicate; 008 009 public ChainingMixer(String name, JoinPredicate predicate) { 010 this.name = name; 011 this.predicate = predicate; 012 } 013 014 protected void join(InputEntry[] inputs, String activatorName, DataSink sink) { 015 if (predicate.toBeJoined(inputs, activatorName)) { 016 sink.addData(chainInputs(inputs)); 017 } 018 } 019 020 public String getName() { 021 return name; 022 } 023 024 }