[MON] Implements multithreading for message consumption