read extractor_info['name']

Author: robkooper

CHANGELOG.md

@@ -12,6 +12,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 ### Fixed
 - Acks were not always send due to racing condition
   [CATS-886](https://opensource.ncsa.illinois.edu/jira/browse/CATS-886)
+- Queue name was not set from extractor_info.json
+  [CATS-896](https://opensource.ncsa.illinois.edu/jira/browse/CATS-896)
 
 ## 2.0.3 - 2018-04-18
 

pyclowder/extractors.py

@@ -57,8 +57,9 @@ def __init__(self):
         # read values from environment variables, otherwise use defaults
         # this is the specific setup for the extractor
         # use RABBITMQ_QUEUE env to overwrite extractor's queue name
-        self.extractor_info['name'] = os.getenv('RABBITMQ_QUEUE', self.extractor_info['name'])
-        rabbitmq_queuename = self.extractor_info['name']
+        rabbitmq_queuename = os.getenv('RABBITMQ_QUEUE')
+        if not rabbitmq_queuename:
+            rabbitmq_queuename = self.extractor_info['name']
         rabbitmq_uri = os.getenv('RABBITMQ_URI', "amqp://guest:[email protected]/%2f")
         rabbitmq_exchange = os.getenv('RABBITMQ_EXCHANGE', "clowder")
         registration_endpoints = os.getenv('REGISTRATION_ENDPOINTS', "")