yudaike/openSUSE-release-tools
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #2485 from andrii-suse/rabbit_repoid_less_aggressive

Browse Source 
Fix MQ timeouts in rabbit-repoid
This commit is contained in:
Stephan Kulow 2020-10-07 13:04:45 +02:00 committed by GitHub
commit ccac00af82
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
gocd/rabbit-repoid.py
View File

@ -32,8 +32,8 @@ class Listener(PubSubConsumer):
return super(Listener, self).interval() return super(Listener, self).interval()
def still_alive(self): def still_alive(self):
self.check_some_repos()
super(Listener, self).still_alive() super(Listener, self).still_alive()
self.check_some_repos()
def routing_keys(self): def routing_keys(self):
return [self.amqp_prefix + '.obs.repo.build_finished'] return [self.amqp_prefix + '.obs.repo.build_finished']
@ -106,7 +106,6 @@ class Listener(PubSubConsumer):
def on_message(self, unused_channel, method, properties, body): def on_message(self, unused_channel, method, properties, body):
self.logger.debug("on_message") self.logger.debug("on_message")
self.check_some_repos()
self.acknowledge_message(method.delivery_tag) self.acknowledge_message(method.delivery_tag)
try: try:
body = json.loads(body) body = json.loads(body)