ganar
Estoy usando el paquete nuget de Microsoft.Azure.ServiceBus para conectarme al bus de servicio de Azure (plan de tarifa: estándar) a través de la función de activación del temporizador de Azure (la función se activa cada 2 minutos). La función se ejecuta en un plan de aplicación (instancia estándar S2 1). La aplicación de funciones lanza excepciones de socket intermitentes cada vez que intenta conectarse al bus de servicio. A continuación se muestra el seguimiento de la pila: –
Estoy usando la clase ManagementClient para obtener el recuento de mensajes activos de la cola de suscripción del bus de servicio usando el método GetSubscriptionRuntimeInfoAsync(). Si el recuento de mensajes es mayor que 0, procese el mensaje; de lo contrario, evítelo. Cualquier sugerencia de por qué recibo el siguiente error: –
Actualización 1: La clase ManagementClient es parte del paquete nuget de Microsoft.Azure.ServiceBus. Y al crear la instancia de ManagementClient, estoy pasando la cadena de conexión del bus de servicio, y recibo excepciones de sockets aquí con el mensaje InnerException como “No se conoce tal host” o, a veces, “Falló un intento de conexión porque la parte conectada no respondió correctamente después de un período de tiempo, o la conexión establecida falló porque el host conectado no respondió”
var managementClient = await _myhelper.GetManagementClient();//returning new instance of managementclient
try
{
var runTimeInfo = await managementClient.GetSubscriptionRuntimeInfoAsync("MyTopicName", "MySubscriptionName");
if (runTimeInfo != null && runTimeInfo.MessageCountDetails.ActiveMessageCount > 0)
{
//Do message processing
}
else
{
//No messages in queue. Hence, return
}
}
finally
{
await managementClient.CloseAsync();
}
Microsoft.Azure.WebJobs.Host.FunctionInvocationException:
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionExecutor+<ExecuteWithLoggingAsync>d__20.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionExecutor.cs:326)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionExecutor+<TryExecuteAsync>d__15.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionExecutor.cs:94)
Inner exception Microsoft.Azure.ServiceBus.ServiceBusException handled at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw:
at Microsoft.Azure.ServiceBus.Management.ManagementClient+<SendHttpRequest>d__53.MoveNext (Microsoft.Azure.ServiceBus, Version= 4.2.0.0, Culture= neutral, PublicKeyToken= 7e34167dcc6d6d8c)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.ServiceBus.Management.ManagementClient+<GetEntity>d__50.MoveNext (Microsoft.Azure.ServiceBus, Version= 4.2.0.0, Culture= neutral, PublicKeyToken= 7e34167dcc6d6d8c)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.ServiceBus.Management.ManagementClient+<GetSubscriptionRuntimeInfoAsync>d__20.MoveNext (Microsoft.Azure.ServiceBus, Version= 4.2.0.0, Culture= neutral, PublicKeyToken= 7e34167dcc6d6d8c)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at +<GetSubscriptionRuntimeInfo>d__6.MoveNext (, Version= 1.0.0.0, Culture= neutral, PublicKeyToken= null: D:\a\1\s\Helper.cs:73)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at d__10.MoveNext ( Version= 1.0.0.0, Culture= neutral, PublicKeyToken= null: D:\a\1\s\Helper.cs:61)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at <Run>d__4.MoveNext ( Version= 1.0.0.0, Culture= neutral, PublicKeyToken= null: D:\a\1\s\myclass.cs:57)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.GetResult(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.VoidTaskMethodInvoker`2+<InvokeAsync>d__2.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\VoidTaskMethodInvoker.cs:20)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionInvoker`2+<InvokeAsync>d__10.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionInvoker.cs:52)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionExecutor+<InvokeWithTimeoutAsync>d__27.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionExecutor.cs:555)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionExecutor+<ExecuteWithWatchersAsync>d__26.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionExecutor.cs:501)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.GetResult(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.WebJobs.Host.Executors.FunctionExecutor+<ExecuteWithLoggingAsync>d__20.MoveNext (Microsoft.Azure.WebJobs.Host, Version= 3.0.29.0, Culture= neutral, PublicKeyToken= 31bf3856ad364e35: C:\projects\azure-webjobs-sdk-rqm4t\src\Microsoft.Azure.WebJobs.Host\Executors\FunctionExecutor.cs:279)
Inner exception System.Net.Http.HttpRequestException handled at Microsoft.Azure.ServiceBus.Management.ManagementClient+<SendHttpRequest>d__53.MoveNext:
at System.Net.Http.ConnectHelper+<ConnectAsync>d__1.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Threading.Tasks.ValueTask`1.get_Result (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1+ConfiguredValueTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.HttpConnectionPool+<ConnectAsync>d__52.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Threading.Tasks.ValueTask`1.get_Result (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1+ConfiguredValueTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.HttpConnectionPool+<CreateHttp11ConnectionAsync>d__53.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Threading.Tasks.ValueTask`1.get_Result (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1+ConfiguredValueTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.HttpConnectionPool+<GetHttpConnectionAsync>d__45.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Threading.Tasks.ValueTask`1.get_Result (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1+ConfiguredValueTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at **System.Net.Http.HttpConnectionPool**+<SendWithRetryAsync>d__47.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredTaskAwaitable`1+ConfiguredTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.RedirectHandler+<SendAsync>d__4.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredTaskAwaitable`1+ConfiguredTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.DiagnosticsHandler+<SendAsync>d__2.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.ConfiguredTaskAwaitable`1+ConfiguredTaskAwaiter.GetResult (System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.HttpClient+<FinishSendAsyncBuffered>d__70.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at Microsoft.Azure.ServiceBus.Management.ManagementClient+<SendHttpRequest>d__53.MoveNext (Microsoft.Azure.ServiceBus, Version= 4.2.0.0, Culture= neutral, PublicKeyToken= 7e34167dcc6d6d8c)
Inner exception System.Net.Sockets.SocketException handled at System.Net.Http.ConnectHelper+<ConnectAsync>d__1.MoveNext:
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(System.Private.CoreLib, Version= 4.0.0.0, Culture= neutral, PublicKeyToken= 7cec85d7bea7798e)
at System.Net.Http.ConnectHelper+<ConnectAsync>d__1.MoveNext (System.Net.Http, Version= 4.2.2.0, Culture= neutral, PublicKeyToken= b03f5f7f11d50a3a)
¿Podría compartir el código de ayuda y elaborar lo que está tratando de lograr para evitar adivinar?
– Sean Feldmann
11 de agosto de 2021 a las 13:15
@SeanFeldman: Actualicé los detalles de mi pregunta, no hay nada como tal en el código de ayuda para compartir, solo devuelvo una nueva instancia de ManagementClient en mi clase de ayuda, es decir, // devuelvo nuevo ManagementClient (MyServicebusConnectionstring); Estoy tratando de obtener el recuento de mensajes activos de la cola de suscripción del bus de servicio y, si el recuento es mayor que 0, estoy procesando los mensajes que devuelven. Por favor, hágamelo saber si esto responde a su pregunta.
– ganar
11 de agosto de 2021 a las 17:29
abrir una conexión al autobús de servicio no es una operación barata. Sería mejor seguir la recomendación y mantenerla en caché, especialmente porque su función se activa cada 2 minutos y se reutiliza la misma instancia. Eso al menos reducirá las posibilidades de tener un error de conectividad ya que habrá menos intentos. Encontrarás la información necesaria aquí. Decir que no deberías recibir tantos errores. A menos que tenga demasiadas (>5000) conexiones a su espacio de nombres. Prueba y hazme saber si funciona.
– Sean Feldmann
11 de agosto de 2021 a las 22:16