Implemented basic message queue + tests: ToDo find correct shards