log functionality added
consume functions is parallelized now