MQ Devel

Now we can use rabbitmq or other mq, this patch is for testing, not for production
Note, however, that the object `startConsuming` returns (via a Deferred) needs to be a `QueueRef`, and in particular it must have a `stopConsuming` method.  What you're returning here is a `kombu.Consumer` instance, which does not meet that requirement.