Merge "[MON] Implements multithreading for message consumption"