proper shutdown of receiver listeners
This commit is contained in:
parent
687e1be3e5
commit
bde54aba3b
|
@ -218,11 +218,13 @@ def stop_all():
|
||||||
listeners = list(_all_listeners.values())
|
listeners = list(_all_listeners.values())
|
||||||
_all_listeners.clear()
|
_all_listeners.clear()
|
||||||
|
|
||||||
for l in listeners:
|
if listeners:
|
||||||
if l:
|
_log.info("stopping %s", listeners)
|
||||||
l.stop()
|
|
||||||
for l in listeners:
|
for l in listeners:
|
||||||
if l:
|
if l:
|
||||||
|
l.stop()
|
||||||
|
for l in listeners:
|
||||||
l.join()
|
l.join()
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue