[Errno 107] Transport endpoint is not connected

[gborrageiro]

Hello,

When trying to post messages to a nats server, I am getting regular errors of the form:

[Errno 107] Transport endpoint is not connected

I set up the connection as follows:

self.nats_client = NATSClient(
            url=self.nats_url, socket_timeout=60., socket_keepalive=True, verbose=True
        )
        self.nats_client.connect()

After I receive the error, I try setting up the connection again:

        try:
            self.nats_client.publish(
                subject=self.nats_subject,
                payload=json.dumps(
                    self.nats_msg, indent=2
                ).encode('utf-8')
            )
        except Exception as e:
            self.nats_client.close()
            self.nats_client.connect()

Am I expected to run self.nats_client.connect() each time before I try publish? There is a performance cost for doing so, which is why I have tried to avoid doing it regularly.

Thanks
Gabriel