Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/PaddlePaddle/FastDeploy
/ queue
Method
queue
fastdeploy/inter_communicator/fmq.py:339–340 ·
view source on GitHub ↗
(self, name: str, role="producer")
Source
from the content-addressed store, hash-verified
337
return
cls._instance
338
339
def
queue(self, name: str, role=
"producer"
) -> Queue:
340
return
Queue(self._context, name, role)
341
342
def
topic(self, name: str) -> Topic:
343
return
Topic(self._context, name)
Callers
14
producer_task
Function · 0.95
consumer_task
Function · 0.95
_init_control
Method · 0.80
__init__
Method · 0.80
init_control
Method · 0.80
q_a2e_producer
Method · 0.80
q_a2e_consumer
Method · 0.80
q_e2w_producer
Method · 0.80
q_e2w_consumer
Method · 0.80
q_w2e_producer
Method · 0.80
q_w2e_consumer
Method · 0.80
q_e2a_producer
Method · 0.80
Calls
1
Queue
Class · 0.85
Tested by
1
run_test
Method · 0.64