code: def __init__(
      self, name, max_queue_memory=0, retry_count=0, retry_interval=0
  ):
      self._client = None
  
      self.retry_count = retry_count or 1
      self.retry_interval = retry_interval
      self._needs_reconnect = False
  
      self.max_memory_usage = max_queue_memory
      self.current_memory_usage = 0
  
      self._shutdown = False
      self._queue = queue.Queue()
      self._name = name
  
      self._thread = threading.Thread(target=self.worker)
      self._thread.daemon = True
      self._thread.start()
  
file_path: aim/aim/ext/transport/rpc_queue.py
imports: import time
  import queue
  import logging
  import threading
  import weakref
label_desc: Use image node_id 1 to create a new RpcQueueWithRetry object from inherited base classes: object with example: obj = RpcQueueWithRetry(name, max_queue_memory, retry_count, retry_interval)