def prepare_message(self, body, priority=None, content_type=None,
                        content_encoding=None, headers=None, properties=None):
        return amqp.Message(body, priority=priority,
                            content_type=content_type,
                            content_encoding=content_encoding,
                            application_headers=headers,
                            **properties)
Encapsulate data into a AMQP message.
dataset/ETHPy150Open celery/kombu/kombu/transport/amqplib.py/Channel.prepare_message