diff --git a/src/main/java/beamline/sources/StringTestSource.java b/src/main/java/beamline/sources/StringTestSource.java new file mode 100644 index 0000000000000000000000000000000000000000..613adb619066291ccf56c9c379344a73f6fe7a23 --- /dev/null +++ b/src/main/java/beamline/sources/StringTestSource.java @@ -0,0 +1,22 @@ +package beamline.sources; + +import beamline.events.BEvent; + +public class StringTestSource extends BeamlineAbstractSource { + + private static final long serialVersionUID = 7657971352128040279L; + private String[] traces; + + public StringTestSource(String...traces) { + this.traces = traces; + } + + @Override + public void run(SourceContext<BEvent> ctx) throws Exception { + for (int j = 0; j < traces.length; j++) { + for (int i = 0; i < traces[j].length(); i++) { + ctx.collect(BEvent.create("test-process", traces[j].substring(i, i+1), "case-"+j)); + } + } + } +}