

def publish(self, exchange, routing_key, headers, body):
    msg = Message(body, headers)
    self._channel.basic.publish(msg, exchange, routing_key)

dataset/ETHPy150Open seatgeek/cronq/cronq/runner.py AMQPProxy.publish/original