updating master (#307)

* Fix structlog dependency for app (#280)

* zipfile fix (#284)

* Fix bug 286 random token replacement (#287)

* Fix bug 286 random token replacement

* Change perdayvolume generator logic to get random token value replacement

* Versioning scheme (#278)

* [global] perDayVolume (#288)

* exclude global from perDayVolume assignment

* Address comment

* Fix security vulnerability issue (#289)

* Fix custom plugin stale docs (#290)

* Server fix (#293)

* Flag added

* server fix for count and env clean

* Fix bug 285 (#297)

* Add syslogAddHeader config directive (#296)

* Add syslog header to event in syslog mode

* timezone setting bugfix #249

* Using multiprocess pool to address the OOM issue (#301)

* Using multiprocess pool to address the OOM issue

* Fix test case fail

* Remove workerQueue unfinished tasks (#302)

* Bumped version to 6.5.2

* controller fix (#304)

* controller fix

* variable assignment fix (#306)

splunk_eventgen/eventgen_api_server/eventgen_controller_api.py

@@ -56,11 +56,11 @@ def gather_response(target_job, message_uuid, response_number_target=0):
                     if message and type(message.get('data')) == str:
                         server_response = json.loads(message.get('data'))
                         self.logger.info(server_response)
-                        message_uuid = server_response.get('message_uuid')
-                        if message_uuid:
-                            if message_uuid not in self.server_responses:
-                                self.server_responses[message_uuid] = {}
-                            self.server_responses[message_uuid][server_response['host']] = server_response['response']
+                        response_message_uuid = server_response.get('message_uuid')
+                        if response_message_uuid:
+                            if response_message_uuid not in self.server_responses:
+                                self.server_responses[response_message_uuid] = {}
+                            self.server_responses[response_message_uuid][server_response['host']] = server_response['response']
             return self.server_responses.get(message_uuid, {})
 
         @bp.route('/index', methods=['GET'])