core: remove old blocking call guard, it's in the wrong place

It should have been in Receiver.get(). Placing it here prevents
*_async() method calls from broker thread.
pull/607/head
David Wilson 6 years ago
parent 0f63ca4c68
commit 7e51a93231

@ -2046,9 +2046,6 @@ class Context(object):
:class:`Receiver` configured to receive any replies sent to the :class:`Receiver` configured to receive any replies sent to the
message's `reply_to` handle. message's `reply_to` handle.
""" """
if self.router.broker._thread == threading.currentThread(): # TODO
raise SystemError('Cannot making blocking call on broker thread')
receiver = Receiver(self.router, persist=persist, respondent=self) receiver = Receiver(self.router, persist=persist, respondent=self)
msg.dst_id = self.context_id msg.dst_id = self.context_id
msg.reply_to = receiver.handle msg.reply_to = receiver.handle

Loading…
Cancel
Save