fix bugs with rabbit mq dispoce
observe on default scheduler