fixed import and consumer thread