MCPcopy
hub / github.com/celery/celery / send_task_message

Method send_task_message

celery/app/amqp.py:264–265  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

262
263 @cached_property
264 def send_task_message(self):
265 return self._create_task_sender()
266
267 def Queues(self, queues, create_missing=None, create_missing_queue_type=None,
268 create_missing_queue_exchange_type=None, autoexchange=None, max_priority=None):

Callers 15

test_send_task_message__no_kwargsMethod · 0.80
test_send_task_message__propertiesMethod · 0.80
test_send_task_message__headersMethod · 0.80
test_send_task_message__queue_stringMethod · 0.80
test_send_task_message__broadcast_without_exchangeMethod · 0.80
test_send_event_exchange_direct_with_exchangeMethod · 0.80
test_send_event_exchange_direct_with_routing_keyMethod · 0.80
test_send_event_exchange_stringMethod · 0.80
test_send_task_message__with_delivery_modeMethod · 0.80
test_send_task_message__with_timeoutMethod · 0.80
test_send_task_message__with_confirm_timeoutMethod · 0.80
test_send_task_message__with_receiversMethod · 0.80

Calls 3

_create_task_senderMethod · 0.95
updateMethod · 0.45
publishMethod · 0.45

Tested by 15

test_send_task_message__no_kwargsMethod · 0.64
test_send_task_message__propertiesMethod · 0.64
test_send_task_message__headersMethod · 0.64
test_send_task_message__queue_stringMethod · 0.64
test_send_task_message__broadcast_without_exchangeMethod · 0.64
test_send_event_exchange_direct_with_exchangeMethod · 0.64
test_send_event_exchange_direct_with_routing_keyMethod · 0.64
test_send_event_exchange_stringMethod · 0.64
test_send_task_message__with_delivery_modeMethod · 0.64
test_send_task_message__with_timeoutMethod · 0.64
test_send_task_message__with_confirm_timeoutMethod · 0.64
test_send_task_message__with_receiversMethod · 0.64