a0a7c50bcb7455215869fe3551c3b695bb35e616,dino/endpoint/pubsub.py,PubSub,do_publish_external,#PubSub#Any#,191

Before Change

        message_type = "external"
        queue_connection = self.env.external_queue_connection
        if queue_connection is None:
            return None
        exchange = self.env.external_exchange
        queue = self.env.external_queue

        try:

After Change

    def do_publish_external(self, message: dict):
        try:
            return self.publisher.publish(message)
        except PublishException:
            logger.error("failed to publish external event multiple times! Republishing to internal queue")
            self.do_publish(message, external=False)
        except Exception as e:

Instances