Consume from queue in same thread

Simplify code with a kombu helper
Merge pull request #15 from onefinestay/consuming-thread-safety

Consume from queue in same thread