def test_update_alarm_req(self, resp, update_alarm, update_resp, get_creds):
"""Test Aodh update alarm request message from KafkaProducer."""
# Set-up message, producer and consumer for tests
def test_update_alarm_req(self, resp, update_alarm, update_resp, get_creds):
"""Test Aodh update alarm request message from KafkaProducer."""
# Set-up message, producer and consumer for tests