'Prepare message so that it can be sent using this transport.'

def prepare_message(self, body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None, _Message=amqp.Message):

    return _Message(body, priority=priority, content_type=content_type, content_encoding=content_encoding, application_headers=headers, **(properties or {}))
