'Publish message.
Arguments:
message (Union[kombu.Message, str, bytes]):
Message to publish.
routing_key (str): Message routing key.
mandatory (bool): Currently not supported.
immediate (bool): Currently not supported.'

def publish(self, message, routing_key=None, mandatory=False, immediate=False, exchange=None):

    if isinstance(message, string_t):
        message = self.Message(message)
    exchange = (exchange or self.name)
    return self.channel.basic_publish(message, exchange=exchange, routing_key=routing_key, mandatory=mandatory, immediate=immediate)
