'Reproduce full life cycle of the message'

def send_and_consume(self, channel, content={}, fail_on_none=True):

    self.send(channel, content)
    return self.consume(channel, fail_on_none=fail_on_none)
