for #1346 message_ttl is not a queue option, used for posting

Author: petersilva

sarracenia/config/__init__.py

@@ -176,7 +176,7 @@ def __repr__(self) -> str:
 
 # options that apply to queues, and so must appear before subtopic resolves queues characteristics.
 #
-queue_options = [ 'auto_delete', 'broker', 'durable', 'exchange', 'exchangeSuffix', 'expire', 'message_ttl', 'prefetch', \
+queue_options = [ 'auto_delete', 'broker', 'durable', 'exchange', 'exchangeSuffix', 'expire', 'prefetch', \
                     'qos', 'queueBind',  'queueDeclare' ]
 
 size_options = ['accelThreshold', 'blockSize', 'bufSize', 'byteRateMax', 'fileSizeMax', 'inlineByteMax']

sarracenia/config/subscription.py

@@ -13,7 +13,7 @@ def __init__(self, options, queueName, subtopic):
         self['bindings'] = [ { 'exchange': options.exchange, 'prefix': options.topicPrefix, 'sub': subtopic } ]
 
         self['queue']={ 'name': queueName, 'cleanup_needed': None }
-        for a in [ 'auto_delete', 'durable', 'expire', 'message_ttl', 'prefetch', 'qos', 'queueBind', 'queueDeclare' ]:
+        for a in [ 'auto_delete', 'durable', 'expire', 'prefetch', 'qos', 'queueBind', 'queueDeclare' ]:
             aa = a.replace('queue','').lower()
             if hasattr(options, a) and getattr(options,a):
                 self['queue'][aa] = getattr(options,a)

sarracenia/moth/amqp.py

@@ -284,7 +284,7 @@ def _queueDeclare(self,passive=False) ->  int:
                     x = int(self.o['messageAgeMax'] * 1000)
                     if x > 0: args['x-message-ttl'] = x
 
-                #FIXME: conver expire, message_ttl to proper units.
+                #FIXME: convert expire, message_ttl to proper units.
                 if self.o['dry_run']:
                     logger.info('queue declare (dry run) %s (as: %s) ' %
                             (self.o['queueName'], broker_str))