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