'Deliver message.'

def _put(self, queue, message, **kwargs):

    pri = self._get_message_priority(message, reverse=False)
    with self.conn_or_acquire() as client:
        client.lpush(self._q_for_pri(queue, pri), dumps(message))
