code: async def publish(self, endpoint: str, payload: str):
          
          if self._conn is not None:
              try:
                  await self._conn.publish(endpoint, payload)
                  return True
              except redis.Error as e:
                  self._logger.error('Publish failed with error %s', repr(e))
          return False
docs: Publish to an endpoint.
          :param str endpoint: Key by which the endpoint is recognised.
                           Subscribers will use this key to listen to events
          :param str payload: Payload to publish with the event
          :return: A boolean indicating if the publish was successful