def _put(self, queue, message, **kwargs):
        q = self._new_queue(queue)
        q.push(dumps(message))
Initialize the database.
dataset/ETHPy150Open celery/kombu/kombu/transport/SLMQ.py/Channel._put--crossover with--dataset/ETHPy150Open starcraftman/new-awesome/db/common.py/init_db