class_docstr: This publisher will handle failures and closures and will
  attempt to restart things
  
  delivery confirmations are used to track messages that have
  been sent and if they have been confirmed
docstr: When the connection is established, the _on_connection_open method
  will be invoked by pika. If you want the reconnection to work, make
  sure you set stop_ioloop_on_close to False, which is not the default
  behavior of this adapter.
  
  :rtype: pika.SelectConnection
docstr_tok: ["When","the","connection","is","established",",","the","_on_connection_open","method","will","be","invoked","by","pika",".","If","you","want","the","reconnection","to","work",",","make","sure","you","set","stop_ioloop_on_close","to","False",",","which","is","not","the","default","behavior","of","this","adapter",".",":","rtype",":","pika.SelectConnection"]
code: def connect(self):
      """
      When the connection is established, the _on_connection_open method
      will be invoked by pika. If you want the reconnection to work, make
      sure you set stop_ioloop_on_close to False, which is not the default
      behavior of this adapter.
  
      :rtype: pika.SelectConnection
  
      """
      params = pika.URLParameters(self._url)
      new_connection = pika.SelectConnection(
          params,
          on_open_callback=self._on_connection_open,
          on_open_error_callback=self._on_connection_error,
          on_close_callback=self._on_connection_closed,
          custom_ioloop=None,
          internal_connection_workflow=True,
      )
      return new_connection
  
imports: import time
  import threading
  import pika
  from studio.storage.storage_setup import get_storage_verbose_level
  from studio.util import logs
label_desc: Use image node_id 4 for calling the RMQueue obj's underlying member method code with example usage: obj.connect() and returns: new_connection