code: async def open(self):
          
          self.store.register(self)
          while not self.finished:
              message = await self.messages.get()
              await self.publish(message)
docs: Register with the publisher.