Method __init__

fastdeploy/inter_communicator/fmq.py:277–283

(self, context, name: str)

class Topic(BaseComponent):
    def __init__(self, context, name: str):
        endpoint = EndpointManager.get_endpoint(name)
        super().__init__(context, endpoint)
        self.name = name
        self._pub_socket = None
        self._sub_socket = None
        self._task = None

    async def pub(self, data: Any):
        # Publish a message