Tag: AZURESERVICEBUS
Tengo un proceso que consume elementos del tema Azure Service Bus. Si todo va bien no hay problema, pero si el proceso encuentra un error, necesito volver a intentar consumir el elemento fallido. Aquí está mi controlador de mensajes: “`public async Task StartRecieverAsync() { var messageHandlerOptions = new MessageHandlerOptions(ExceptionReceivedHandler) { . . . Read more
Estoy intentando implementar un servicio ASP.NET Core Web API que reciba mensajes en Azure Service Bus usando Docker / Azure Kubernetes, pero estoy teniendo problemas con el puerto bloqueado. Aquí están mis archivos de implementación: Dockerfile FROM mcr.microsoft.com/dotnet/aspnet:5.0 AS base WORKDIR /app EXPOSE 8004 EXPOSE 5671 EXPOSE 5672 ENV ASPNETCORE_URLS=http://+:8004 . . . Read more
Estoy usando el cliente npm @azure/service-bus (7.0.0) para enviar mensajes programados, pero no se están enviando. Todos están fallando con el siguiente error: {“name”:”ServiceBusError”,”retryable”:false,”code”:”GeneralError”}}. El siguiente fragmento de código es como estoy desencadenando la acción: const sbClient = this.getInstance(); const sender = sbClient.createSender(queueOrTopic); await sender.scheduleMessages(message, scheduleTimeUtc); “`
¿Existe alguna forma de recibir solo mensajes de una cola de Azure Service Bus con un identificador de correlación específico? El escenario es el siguiente: 1. Recibo una llamada a la API REST en mi aplicación A 2. Mi aplicación A generará un identificador de correlación único 3. Mi aplicación . . . Read more
Tengo un ServiceBusTrigger para ServiceBusQueues.QUEUE_NAME. [Function(nameof(QueueProcess))] public async Task QueueProcess([ServiceBusTrigger(ServiceBusQueues.QUEUE_NAME, Connection = "ConnectionString")] string message) { try { Console.Write(message); } catch (Exception ex) { throw; } } Cuando envío un mensaje allí, lo intenta 10 veces y mueve el mensaje a Dead-Letter. No hay ningún error, la función termina satisfactoriamente. . . . Read more