Refactor a little
Set an idle timeout to Consumer actor
Stub events generator is now handled by an actor