跳过内容

message_publishers#

MessageQueuePublisherMixin #

基类: ABC

发布者 Mixin。

消息队列发布者的 Mixin。允许访问以下常用属性和方法： - 发布者 ID。 - 消息队列。 - 发布回调。 - 发布方法。

源代码位于 llama_deploy/message_publishers/publisher.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
class MessageQueuePublisherMixin(ABC):
    """PublisherMixin.

    Mixin for a message queue publisher. Allows for accessing common properties and methods for:
    - Publisher ID.
    - Message queue.
    - Publish callback.
    - Publish method.
    """

    @property
    @abstractmethod
    def publisher_id(self) -> str: ...

    @property
    @abstractmethod
    def message_queue(self) -> AbstractMessageQueue: ...

    @property
    def publish_callback(self) -> Optional[PublishCallback]:
        return None

    @abstractmethod
    def get_topic(self, msg_type: str) -> str: ...

    async def publish(self, message: QueueMessage, **kwargs: Any) -> Any:
        """Publish message."""
        message.publisher_id = self.publisher_id
        return await self.message_queue.publish(
            message,
            callback=self.publish_callback,
            topic=self.get_topic(message.type),
            **kwargs,
        )

publish async #

publish(message: QueueMessage, **kwargs: Any) -> Any

发布消息。

源代码位于 llama_deploy/message_publishers/publisher.py 
33
34
35
36
37
38
39
40
41
async def publish(self, message: QueueMessage, **kwargs: Any) -> Any:
    """Publish message."""
    message.publisher_id = self.publisher_id
    return await self.message_queue.publish(
        message,
        callback=self.publish_callback,
        topic=self.get_topic(message.type),
        **kwargs,
    )