MCPcopy 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_taskFunction · 0.95
consumer_taskFunction · 0.95
_init_controlMethod · 0.80
__init__Method · 0.80
init_controlMethod · 0.80
q_a2e_producerMethod · 0.80
q_a2e_consumerMethod · 0.80
q_e2w_producerMethod · 0.80
q_e2w_consumerMethod · 0.80
q_w2e_producerMethod · 0.80
q_w2e_consumerMethod · 0.80
q_e2a_producerMethod · 0.80

Calls 1

QueueClass · 0.85

Tested by 1

run_testMethod · 0.64