code: def get_publisher():
      
      log.info("initializing publisher")
      pub = None
      auth_url = ""
      if FORWARD_ENDPOINT_TYPE == "redis":
          auth_url = FORWARD_BROKER_URL
      else:
          auth_url = FORWARD_BROKER_URL
  
      pub = Publisher(name="{}_{}".format(SOURCE, "-redis"),
                      auth_url=auth_url,
                      ssl_options=FORWARD_SSL_OPTIONS)
  
      log.info("publisher={}".format(pub))
      return pub
docs: get_publisher