CampaignQueueConsumer should be responsible for get the lastId processed from file and passing it to $datasource process method. Also now we only use lastId stored in file if $startId in processMessage is null