|
@@ -441,9 +441,6 @@ class AMQP:
|
|
send_after_publish = signals.after_task_publish.send
|
|
send_after_publish = signals.after_task_publish.send
|
|
after_receivers = signals.after_task_publish.receivers
|
|
after_receivers = signals.after_task_publish.receivers
|
|
|
|
|
|
- send_task_sent = signals.task_sent.send # XXX compat
|
|
|
|
- sent_receivers = signals.task_sent.receivers
|
|
|
|
-
|
|
|
|
default_evd = self._event_dispatcher
|
|
default_evd = self._event_dispatcher
|
|
default_exchange = self.default_exchange
|
|
default_exchange = self.default_exchange
|
|
|
|
|
|
@@ -521,10 +518,6 @@ class AMQP:
|
|
if after_receivers:
|
|
if after_receivers:
|
|
send_after_publish(sender=name, body=body, headers=headers2,
|
|
send_after_publish(sender=name, body=body, headers=headers2,
|
|
exchange=exchange, routing_key=routing_key)
|
|
exchange=exchange, routing_key=routing_key)
|
|
- if sent_receivers: # XXX deprecated
|
|
|
|
- send_task_sent(sender=name, task_id=body['id'], task=name,
|
|
|
|
- args=body['args'], kwargs=body['kwargs'],
|
|
|
|
- eta=body['eta'], taskset=body['taskset'])
|
|
|
|
if sent_event:
|
|
if sent_event:
|
|
evd = event_dispatcher or default_evd
|
|
evd = event_dispatcher or default_evd
|
|
exname = exchange
|
|
exname = exchange
|