Adding support for retry policy (SupportsRetryAttribute)

Author: alrod

eng/Packages.Data.props

@@ -126,7 +126,7 @@
     <PackageReference Update="Microsoft.Azure.SignalR.Management" Version="1.16.1" />
     <PackageReference Update="Microsoft.Azure.SignalR.Protocols" Version="1.16.1" />
     <PackageReference Update="Microsoft.Azure.SignalR.Serverless.Protocols" Version="1.6.0" />
-    <PackageReference Update="Microsoft.Azure.WebJobs" Version="3.0.31" />
+    <PackageReference Update="Microsoft.Azure.WebJobs" Version="3.0.32" />
     <PackageReference Update="Microsoft.Azure.WebJobs.Sources" Version="3.0.30" />
     <PackageReference Update="Microsoft.Spatial" Version="7.5.3" />
     <PackageReference Update="Newtonsoft.Json" Version="10.0.3" />

sdk/eventhub/Microsoft.Azure.WebJobs.Extensions.EventHubs/CHANGELOG.md

@@ -1,14 +1,8 @@
 # Release History
 
 ## 5.1.0-beta.1 (Unreleased)
-
 ### Features Added
-
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Adding support for retry policy (SupportsRetryAttribute)
 
 ## 5.0.1 (2022-03-09)
 

sdk/eventhub/Microsoft.Azure.WebJobs.Extensions.EventHubs/src/Triggers/EventHubTriggerAttributeBindingProvider.cs

@@ -70,11 +70,11 @@ public Task<ITriggerBinding> TryCreateAsync(TriggerBindingProviderContext contex
                                                 _loggerFactory);
                  return Task.FromResult(listener);
              };
-
 #pragma warning disable 618
             ITriggerBinding binding = BindingFactory.GetTriggerBinding(new EventHubTriggerBindingStrategy(), parameter, _converterManager, createListener);
 #pragma warning restore 618
-            return Task.FromResult(binding);
+            ITriggerBinding eventHubTriggerBindingWrapper = new EventHubTriggerBindingWrapper(binding);
+            return Task.FromResult(eventHubTriggerBindingWrapper);
         }
     } // end class
 }

sdk/eventhub/Microsoft.Azure.WebJobs.Extensions.EventHubs/src/Triggers/EventHubTriggerBindingWrapper.cs

@@ -0,0 +1,44 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.Azure.WebJobs.Host;
+using Microsoft.Azure.WebJobs.Host.Bindings;
+using Microsoft.Azure.WebJobs.Host.Listeners;
+using Microsoft.Azure.WebJobs.Host.Protocols;
+using Microsoft.Azure.WebJobs.Host.Triggers;
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Microsoft.Azure.WebJobs.EventHubs
+{
+    [SupportsRetry]
+    internal class EventHubTriggerBindingWrapper : ITriggerBinding
+    {
+        private readonly ITriggerBinding _innerTriggerBinding;
+
+        public EventHubTriggerBindingWrapper(ITriggerBinding triggerBinding)
+        {
+            _innerTriggerBinding = triggerBinding;
+        }
+
+        public Type TriggerValueType => _innerTriggerBinding.TriggerValueType;
+
+        public IReadOnlyDictionary<string, Type> BindingDataContract => _innerTriggerBinding.BindingDataContract;
+
+        public async Task<ITriggerData> BindAsync(object value, ValueBindingContext context)
+        {
+            return await _innerTriggerBinding.BindAsync(value, context).ConfigureAwait(false);
+        }
+
+        public async Task<IListener> CreateListenerAsync(ListenerFactoryContext context)
+        {
+            return await _innerTriggerBinding.CreateListenerAsync(context).ConfigureAwait(false);
+        }
+
+        public ParameterDescriptor ToParameterDescriptor()
+        {
+            return _innerTriggerBinding.ToParameterDescriptor();
+        }
+    }
+}