Fix Utils: Messagebus expire interface fix (Seagate#689)

* Fix init phase of Miniprovisioning (Seagate#645)

* Fix init phase of Miniprovisioning

Signed-off-by: Selvakumar <[email protected]>

* Fix test cases related to message_bus

Signed-off-by: Selvakumar <[email protected]>

* Remove creation of config files

Signed-off-by: Selvakumar <[email protected]>

* Make use of components logger (Seagate#650)

* Make use of components logger

Signed-off-by: Selvakumar <[email protected]>

* Use utils logger if initialised

Signed-off-by: Selvakumar <[email protected]>

* Ignore logging in message_bus if logger is not initialised (Seagate#652)

* Ignore logging if logger is not initialised

Signed-off-by: Selvakumar <[email protected]>

* Ignore logging if logger is not initialised

Signed-off-by: Selvakumar <[email protected]>

* Updated message_bus tests to take cluster.conf path as input and get kafka endpoints from conf. (Seagate#658)

* PATCH: update PyYaml version

Signed-off-by: Rohit Dwivedi <[email protected]>

* EOS-25893: Implement init method for Event_message (Seagate#670)

* Iem prep and messagebus init changes

Signed-off-by: suryakumar.kumaravelan <[email protected]>

* Update event_message.py

* Update event_message.py

* Update event_message.py

* Update test_iem.py

* Update event_message.py

* Update test_iem.py

* Update event_message.py

Co-authored-by: Sachin Punadikar <[email protected]>
Co-authored-by: Selva Nambi <[email protected]>

* MessageBus library code should not refer any conf file (Seagate#644)

* EOS-25892: Implement init method for message_bus (Seagate#610)

* Read passed in config values

Signed-off-by: Selvakumar <[email protected]>

* modify the testcases

Signed-off-by: Selvakumar <[email protected]>

* Initialize logger

Signed-off-by: Selvakumar <[email protected]>

* change parameter name

Signed-off-by: Selvakumar <[email protected]>

* Read conf values in MiniProvisioning init phase

Signed-off-by: Selvakumar <[email protected]>

* dump dict to json string

Signed-off-by: Selvakumar <[email protected]>

* EOS-25892: Implement MessageBus.init() (Seagate#639)

* Read the passed in config

Signed-off-by: Selvakumar <[email protected]>

* Read kwargs

Signed-off-by: Selvakumar <[email protected]>

* change config params

Signed-off-by: Selvakumar <[email protected]>

* Remove Invalid line

Signed-off-by: Selvakumar <[email protected]>

* EOS-26899: Message server changes for init argument (Seagate#642)

* Message server changes for init argument fixes

Signed-off-by: suryakumar.kumaravelan <[email protected]>

* code optimize

Signed-off-by: suryakumar.kumaravelan <[email protected]>

* Add MessageBus.init() in testcase (Seagate#643)

Signed-off-by: Selvakumar <[email protected]>

* Update test_message_bus.py

Co-authored-by: Selva Nambi <[email protected]>
Co-authored-by: SURYA KUMAR K <[email protected]>

Signed-off-by: Sachin Punadikar <[email protected]>

Conflicts:
	py-utils/src/setup/utils.py
	py-utils/src/utils/message_bus/message_bus.py
	py-utils/src/utils/message_bus/message_bus_client.py

* Messagebus fix for no conf merged branch

Signed-off-by: suryakumar.kumaravelan <[email protected]>

* code fix

Signed-off-by: suryakumar.kumaravelan <[email protected]>

Co-authored-by: Selva Nambi <[email protected]>
Co-authored-by: veerendra-simha-garikipati <[email protected]>
Co-authored-by: Rohit Dwivedi <[email protected]>
Co-authored-by: Sachin Punadikar <[email protected]>
Signed-off-by: suryakumar.kumaravelan <[email protected]>

py-utils/test/message_bus/test_message_bus.py

@@ -246,8 +246,7 @@ def test_017_message_type_read_after_expiry(self):
         _consumer_new = MessageConsumer(consumer_id='receive_new', \
             consumer_group='test_new', \
             message_types=[TestMessageBus._message_type], \
-            auto_ack=False, offset='earliest', \
-            cluster_conf = self.cluster_conf_path)
+            auto_ack=False, offset='earliest')
         message = _consumer_new.receive()
         # Revert back to original timeout to 604800000 (7 days)
         #  and data log size to 1073741824 (1 Gb)