* Move code to rigth package * Move code to correct module
Revert "BAEL-3275: Using blocking queue for pub-sub"