for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
self.assertTrue(info['alarm_create_response']['status'])
return
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete1.json",'delete_alarm_request','','alarm_request')
self.assertTrue(info['alarm_create_response']['status'])
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete2.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_create_response']['status'])
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info,"---"
+ print(info, "---")
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid.json",'delete_alarm_request', '','alarm_request')
self.assertEqual(info, None)
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete3.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_create_response']['status'])
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info,"---"
+ print(info, "---")
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete3.json",'delete_alarm_request', '','alarm_request')
self.assertEqual(info, None)
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete3.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_create_response']['status'])
for message in _consumer:
if message.key == "create_alarm_response":
info = json.loads(json.loads(message.value))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(info,None)
return
for message in _consumer:
if message.key == "update_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid_delete4.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_update_response']['status'])
for message in _consumer:
if message.key == "update_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(info,None)
return
for message in _consumer:
if message.key == "update_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_update_response']['status'])
for message in _consumer:
if message.key == "update_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(info,None)
return
for message in _consumer:
if message.key == "update_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
producer.request("test_schemas/delete_alarm/name_valid.json",'delete_alarm_request', '','alarm_request')
self.assertTrue(info['alarm_update_response']['status'])
for message in _consumer:
if message.key == "delete_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertTrue(info['alarm_deletion_response']['status'])
return
for message in _consumer:
if message.key == "delete_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(info,None)
return
for message in _consumer:
if message.key == "list_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(type(info),dict)
return
for message in _consumer:
if message.key == "list_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(type(info),dict)
return
for message in _consumer:
if message.key == "list_alarm_response":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(type(info),dict)
return
for message in _consumer:
if message.key == "notify_alarm":
info = json.loads(json.loads(json.loads(message.value)))
- print info
+ print(info)
time.sleep(1)
self.assertEqual(type(info),dict)
return