def METHOD_NAME(self, queue_name: str) -> Union[SyftError, SyftSuccess]:
    if queue_name not in self.producers:
        return SyftError(message=f"No producer running for : {queue_name}")
    producer = self.producers[queue_name]
    # close existing connection.
    producer.close()
    # add a new connection
    self.add_producer(queue_name=queue_name, address=producer.address)
    return SyftSuccess(message=f"Queue: {queue_name} successfully purged")