start working on parsing result messages

Scout24 · Nov 12, 2015 · f3f3ba1 · f3f3ba1
1 parent 79c5a8c
commit f3f3ba1
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/integrationtest/python/crassus_integration_tests.py b/src/integrationtest/python/crassus_integration_tests.py
@@ -69,6 +69,8 @@ def test_create_stacks_and_update(self):
 
         self.send_update_message(invoker_role)
 
+        self.wait_for_success_from_crassus()
+
         self.assert_update_successful()
 
     def create_invoker_role(self):
@@ -236,3 +238,10 @@ def ignore_client_error(self, function):
             function()
         except ClientError as exc:
             logger.warning('Exception caught: {0}'.format(exc.message))
+
+    def wait_for_success_from_crassus(self):
+        output_sqs_queue_url = self.get_stack_output(self.crassus_stack_name,
+                                       'outputSqsQueue')
+
+        sqs_client = boto3.client('sqs')
+        sqs_client.receive_message(QueueUrl=output_sqs_queue_url)