'Encapsulate data into a AMQP message.'

def prepare_message(self, body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None):

    properties = (properties if (properties is not None) else {})
    properties.update({u'content_type': content_type, u'content_encoding': content_encoding, u'headers': headers, u'priority': priority})
    return (body, properties)
