Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 3 additions & 4 deletions src/cosalib/fedora_messaging_request.py
Original file line number Diff line number Diff line change
Expand Up @@ -194,8 +194,7 @@ def error_cb(failure):
}
}

for d in twisted_consume(callback, bindings=bindings, queues=queues):
d.addCallback(registered_cb)
d.addErrback(error_cb) # pylint: disable=E1101

consumers = twisted_consume(callback, bindings=bindings, queues=queues)
consumers.addCallback(registered_cb)
consumers.addErrback(error_cb) # pylint: disable=E1101
reactor.run(installSignalHandlers=False) # pylint: disable=E1101
Loading