Changed signature and passed prefetchCount alone.

Author: yojagad

src/Trigger/RabbitMQTriggerAttributeBindingProvider.cs

@@ -68,7 +68,7 @@ public Task<ITriggerBinding> TryCreateAsync(TriggerBindingProviderContext contex
 
             IRabbitMQService service = _provider.GetService(connectionString, hostName, queueName, userName, password, port);
 
-            return Task.FromResult<ITriggerBinding>(new RabbitMQTriggerBinding(service, hostName, queueName, _logger, parameter.ParameterType, _options));
+            return Task.FromResult<ITriggerBinding>(new RabbitMQTriggerBinding(service, hostName, queueName, _logger, parameter.ParameterType, _options.Value.PrefetchCount));
         }
 
         private string Resolve(string name)

src/Trigger/RabbitMQTriggerBinding.cs

@@ -9,7 +9,6 @@
 using Microsoft.Azure.WebJobs.Host.Protocols;
 using Microsoft.Azure.WebJobs.Host.Triggers;
 using Microsoft.Extensions.Logging;
-using Microsoft.Extensions.Options;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 
@@ -19,19 +18,19 @@ internal class RabbitMQTriggerBinding : ITriggerBinding
     {
         private readonly IRabbitMQService _service;
         private readonly ILogger _logger;
-        private readonly IOptions<RabbitMQOptions> _options;
         private readonly Type _parameterType;
         private readonly string _queueName;
         private readonly string _hostName;
+        private readonly ushort _prefetchCount;
 
-        public RabbitMQTriggerBinding(IRabbitMQService service, string hostname, string queueName, ILogger logger, Type parameterType, IOptions<RabbitMQOptions> options)
+        public RabbitMQTriggerBinding(IRabbitMQService service, string hostname, string queueName, ILogger logger, Type parameterType, ushort prefetchCount)
         {
             _service = service;
             _queueName = queueName;
             _hostName = hostname;
             _logger = logger;
             _parameterType = parameterType;
-            _options = options;
+            _prefetchCount = prefetchCount;
             BindingDataContract = CreateBindingDataContract();
         }
 
@@ -60,7 +59,7 @@ public Task<IListener> CreateListenerAsync(ListenerFactoryContext context)
                 throw new ArgumentNullException("context");
             }
 
-            return Task.FromResult<IListener>(new RabbitMQListener(context.Executor, _service, _queueName, _logger, context.Descriptor, _options.Value.PrefetchCount));
+            return Task.FromResult<IListener>(new RabbitMQListener(context.Executor, _service, _queueName, _logger, context.Descriptor, _prefetchCount));
         }
 
         public ParameterDescriptor ToParameterDescriptor()