Update TempFilterFunc binding protocol to Amqp_Tcp_Only (#5571)

yophilav · web-flow · commit a5e559c82352 · 2021-09-27T22:03:39.000Z
Update TempFilterFunc binding protocol to Amqp_Tcp_Only to fix E2E test failure with DotNetty update.
diff --git a/edge-modules/functions/binding/src/Microsoft.Azure.WebJobs.Extensions.EdgeHub/ModuleClientCache.cs b/edge-modules/functions/binding/src/Microsoft.Azure.WebJobs.Extensions.EdgeHub/ModuleClientCache.cs
@@ -53,7 +53,7 @@ public async Task<ModuleClient> GetOrCreateAsync()
 
         async Task<ModuleClient> CreateModuleClient()
         {
-            ModuleClient moduleClient = await ModuleClient.CreateFromEnvironmentAsync(TransportType.Mqtt_Tcp_Only);
+            ModuleClient moduleClient = await ModuleClient.CreateFromEnvironmentAsync(TransportType.Amqp_Tcp_Only);
 
             moduleClient.ProductInfo = "Microsoft.Azure.WebJobs.Extensions.EdgeHub";
             return moduleClient;

Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ public async Task<ModuleClient> GetOrCreateAsync()`
`53`	`53`
`54`	`54`	`async Task<ModuleClient> CreateModuleClient()`
`55`	`55`	`{`
`56`		`- ModuleClient moduleClient = await ModuleClient.CreateFromEnvironmentAsync(TransportType.Mqtt_Tcp_Only);`
	`56`	`+ ModuleClient moduleClient = await ModuleClient.CreateFromEnvironmentAsync(TransportType.Amqp_Tcp_Only);`
`57`	`57`
`58`	`58`	`moduleClient.ProductInfo = "Microsoft.Azure.WebJobs.Extensions.EdgeHub";`
`59`	`59`	`return moduleClient;`