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

consumers :)
Some checks failed
continuous-integration/drone/push Build is failing
Details

Browse Source
This commit is contained in:
Torma Kristóf
2020-04-01 02:20:39 +02:00
parent e0c4d68da5
commit 1e8e3bd86c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
communicator.py
View File

@@ -46,7 +46,7 @@ class Communicator:
""" """
try: try:
currentconsumer = self.currenctconsumer currentconsumer = self.currenctconsumer
response = requests.get(f'http://{currentconsumer}/consumer') response = requests.get(f'http://{currentconsumer}/consumers')
json = response.json() json = response.json()
LOGGER.info(f"List of currently available consumers: {json}") LOGGER.info(f"List of currently available consumers: {json}")
return json return json
@@ -61,7 +61,7 @@ class Communicator:
""" """
currentconsumer = self.currenctconsumer currentconsumer = self.currenctconsumer
try: try:
response = requests.get(f'http://{currentconsumer}/consumer') response = requests.get(f'http://{currentconsumer}/consumers')
isavailable = response.status_code == 200 isavailable = response.status_code == 200
except Exception as e: except Exception as e:
LOGGER.exception(e) LOGGER.exception(e)
@@ -76,7 +76,7 @@ class Communicator:
:return: :return:
""" """
try: try:
response = requests.get(f'http://{consumer}/consumer') response = requests.get(f'http://{consumer}/consumers')
isavailable = response.status_code == 200 isavailable = response.status_code == 200
except Exception as e: except Exception as e:
LOGGER.exception(e) LOGGER.exception(e)