add counting queue length logic
Delete message after processing close #3
Merge pull request #4 from SlavaBobik/dev

Add worker logic