refactored the producers to work same way based on iterator and always inform when last record is sent on generate
created a splitter that splits the results of an aggregator
changed the unique filter to inform when last record was received for duplicates and non duplicates using nomessage
changed filelinewriter to ignore nomessage when writing to file.