Reverted bus post logic for HTTP backend
This commit is contained in:
parent
88d2fbd366
commit
f79de2e708
1 changed files with 1 additions and 1 deletions
|
@ -238,7 +238,7 @@ class HttpBackend(Backend):
|
||||||
msg.origin = 'http'
|
msg.origin = 'http'
|
||||||
|
|
||||||
redis = self._get_redis()
|
redis = self._get_redis()
|
||||||
self.on_message(msg)
|
self.bus.post(msg)
|
||||||
|
|
||||||
if isinstance(msg, Request):
|
if isinstance(msg, Request):
|
||||||
response = redis.blpop(get_redis_queue_name_by_message(msg), timeout=60)
|
response = redis.blpop(get_redis_queue_name_by_message(msg), timeout=60)
|
||||||
|
|
Loading…
Reference in a new issue