text: import abc
  
  
  class BasePublisher(abc.ABC):
      @abc.abstractmethod
      async def connect(self):
          pass
  
      @abc.abstractmethod
      async def close(self):
          pass
  
      @abc.abstractmethod
      async def publish(self, data: str):
          pass
  