Bases: ABC
PublisherMixin.
Mixin for a message queue publisher. Allows for accessing common properties and methods for:
- Publisher ID.
- Message queue.
- Publish callback.
- Publish method.
Source code in 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) -> BaseMessageQueue: ...
@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.
Source code in 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,
)
|
