projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Adds yaml support in policy module
[osm/MON.git]
/
policy_module
/
osm_policy_module
/
common
/
mon_client.py
diff --git
a/policy_module/osm_policy_module/common/mon_client.py
b/policy_module/osm_policy_module/common/mon_client.py
index
0d86046
..
3e81757
100644
(file)
--- a/
policy_module/osm_policy_module/common/mon_client.py
+++ b/
policy_module/osm_policy_module/common/mon_client.py
@@
-50,7
+50,8
@@
class MonClient:
future.get(timeout=60)
consumer = KafkaConsumer(bootstrap_servers=self.kafka_server,
key_deserializer=bytes.decode,
future.get(timeout=60)
consumer = KafkaConsumer(bootstrap_servers=self.kafka_server,
key_deserializer=bytes.decode,
- value_deserializer=bytes.decode)
+ value_deserializer=bytes.decode,
+ consumer_timeout_ms=10000)
consumer.subscribe(['alarm_response'])
for message in consumer:
if message.key == 'create_alarm_response':
consumer.subscribe(['alarm_response'])
for message in consumer:
if message.key == 'create_alarm_response':