diff --git a/src/judas_client/connector.py b/src/judas_client/connector.py index 40a0c05..7f7ec53 100644 --- a/src/judas_client/connector.py +++ b/src/judas_client/connector.py @@ -98,12 +98,18 @@ class Connector: time.sleep(retry_interval) self.connect(retry_interval=min(30, retry_interval * 2)) - def send(self, data: bytes) -> None: + def send(self, data: bytes, no_check_ack: bool = False) -> None: self.logger.debug(f"[>] Sending data: {data}") while True: try: self.socket.sendall(data) - self.logger.info("[>] Data sent") + + if no_check_ack: + self.logger.debug("[>] Data sent without ACK check") + break + else: + self.logger.info("[>] Data sent") + acknowledged: bool = self._check_ack() if acknowledged: self.logger.debug("[.] Data acknowledged")