mirror of https://github.com/celery/kombu.git
virtual: must continue draining events even if no channels (yet) registered
This commit is contained in:
parent
9689ea75af
commit
2d08e34e50
|
@ -562,8 +562,6 @@ class Transport(base.Transport):
|
|||
channel.close()
|
||||
|
||||
def drain_events(self, connection, timeout=None):
|
||||
if not self.channels:
|
||||
raise ValueError("No channels to drain events from.")
|
||||
loop = 0
|
||||
time_start = time()
|
||||
while 1:
|
||||
|
|
Loading…
Reference in New Issue