GoldenPogacsa/producer
Archived
7
0
Fork 0
Code Issues Pull Requests Releases Activity

Learn available consumers after switching current consumer

Browse Source
This commit is contained in:
Scharnitzky Donát
2020-03-29 18:00:00 +02:00
parent 6df7089900
commit 36272830d5
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
consumerlocator.py
View File

@@ -33,9 +33,10 @@ class ConsumerLocator:
"""" """"
Learns the list of consumers. Learns the list of consumers.
""" """
#TODO improve learning recievedconsumerlist = self.communicator.discoveravailableconsumers()
recievedConsumerList = self.communicator.discoveravailableconsumers() if recievedconsumerlist is None:
for consumer in recievedConsumerList: return
for consumer in recievedconsumerlist:
self.consumerList.append({"Host": consumer, "State": True, "LastOk": datetime.datetime.now()}) self.consumerList.append({"Host": consumer, "State": True, "LastOk": datetime.datetime.now()})
self.updateConsumerList() self.updateConsumerList()
@@ -71,6 +72,7 @@ class ConsumerLocator:
break break
self.currentConsumer = newCurrentConsumer self.currentConsumer = newCurrentConsumer
self.learnconsumerlist()
if self.currentConsumer is not None: if self.currentConsumer is not None:
return self.currentConsumer["Host"] return self.currentConsumer["Host"]