@@ -0,0 +1,568 @@
+package org.easybatch.core.filter;%0A%0Aimport org.easybatch.core.api.Record;%0Aimport org.easybatch.core.api.RecordFilter;%0Aimport org.easybatch.core.util.PoisonRecord;%0A%0A/**%0A * Poison records are used as End-Of-Stream signals, usually they have no added value and should be filtered.%0A *%0A * This filter is used to filter such records.%0A *%0A * @author Mahmoud Ben Hassine (mahmoud@benhassine.fr)%0A */%0Apublic class PoisonRecordFilter implements RecordFilter %7B%0A%0A    @Override%0A    public boolean filterRecord(Record record) %7B%0A        return record instanceof PoisonRecord;%0A    %7D%0A%0A%7D%0A

add poison record filter