            # Forwards message
            with conn.Producer(routing_key="PLUGIN_ERROR") as producer:
                producer.publish(newmsg, headers={"source-id": self._queue_name}, priority=message.properties.get("priority"))

            # Send ack
            message.ack()