MCPcopy
hub / github.com/celery/celery / Dispatcher

Method Dispatcher

celery/app/events.py:23–25  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

21
22 @cached_property
23 def Dispatcher(self):
24 return self.app.subclass_with_self(
25 self.dispatcher_cls, reverse='events.Dispatcher')
26
27 @cached_property
28 def State(self):

Callers 14

default_dispatcherMethod · 0.95
test_redis_uses_fanout_exchangeMethod · 0.80
test_others_use_topic_exchangeMethod · 0.80
test_takes_channel_connectionMethod · 0.80
test_sql_transports_disabledMethod · 0.80
test_sendMethod · 0.80
test_send_buffer_groupMethod · 0.80
test_flush_no_groups_no_errorsMethod · 0.80
test_enter_exitMethod · 0.80
test_enable_disable_callbacksMethod · 0.80
test_enabled_disableMethod · 0.80
test_itercapture_limitMethod · 0.80

Calls 1

subclass_with_selfMethod · 0.80

Tested by 11

test_redis_uses_fanout_exchangeMethod · 0.64
test_others_use_topic_exchangeMethod · 0.64
test_takes_channel_connectionMethod · 0.64
test_sql_transports_disabledMethod · 0.64
test_sendMethod · 0.64
test_send_buffer_groupMethod · 0.64
test_flush_no_groups_no_errorsMethod · 0.64
test_enter_exitMethod · 0.64
test_enable_disable_callbacksMethod · 0.64
test_enabled_disableMethod · 0.64
test_itercapture_limitMethod · 0.64