Code cleanup
Add Queue.subsctibe and .publish