@synchronized('lock')
    def basic_publish(self, msg, exchange='', routing_key='', mandatory=False, immediate=False):
        self._basic_publish(msg, exchange, routing_key, mandatory, immediate)
        if self.mode == self.CH_MODE_CONFIRM:
            self.wait(spec.Basic.Ack)
Publish a message
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel.basic_publish