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 {}
        )
Prepares message so that it can be sent using this transport.
dataset/ETHPy150Open celery/kombu/kombu/transport/pyamqp.py/Channel.prepare_message