Tag: AZURE-SERVICEBUS-QUEUES
Intento inyectar un ITest al constructor de Consumer en una aplicación de servicio de Windows utilizando MassTransit, pero falla. Esto es lo que he intentado: Program.cs public class Program { static void Main(string[] args) { CreateHostBuilder(args).Build().Run(); } public static IHostBuilder CreateHostBuilder(string[] args) => Host.CreateDefaultBuilder(args) .ConfigureServices((hostContext, services) => { ConfigureServices(services); }).UseWindowsService(); . . . Read more
Soy nuevo en el uso y configuración de Azure Relay. Desarrollé una API que responde con el mecanismo de Relay… Ahora mi necesidad es dejar los escuchadores del servicio bus configurados por defecto en Program (o incluso en startup) de esta manera: webBuilder.UseAzureRelay(options => { options.UrlPrefixes.Add(Configuration.GetSection(“AzureRelay”) .GetValue(“SB_HC_CONNECTIONSTRING”)); }) Ahora necesito . . . Read more
Tenemos una arquitectura construida alrededor del bus de servicios, que funciona bien. Actualmente también estamos utilizando el mismo bus de servicios con espacios de nombres para registrar nuestras actividades a través de un sink personalizado de Serilog (que será reemplazado con datadog). Esto ha causado que en nuestro ambiente de . . . Read more
Estoy utilizando Azure.Messaging.ServiceBus para obtener mensajes en la cola mediante PeekMessageAsync() para encontrar mensajes no completados que necesitan ser eliminados, pero llamar a CompleteMessageAsync() no tiene ningún efecto. (¿”Completar” un mensaje en la cola es cómo supongo que se eliminan los elementos?) Como parte de mi depuración, decidí actualizar a . . . Read more
Tengo una aplicación Spring Boot, donde recibo un único mensaje de una sesión de cola de Azure Service Bus. El código es: @Autowired ServiceBusSessionReceiverAsyncClient apiMessageQueueIntegrator; . . . Mono<ServiceBusReceiverAsyncClient> receiverMono = apiMessageQueueIntegrator.acceptSession(sessionid); Disposable subscription = Flux.usingWhen(receiverMono, receiver -> receiver.receiveMessages(), receiver -> Mono.fromRunnable(() -> receiver.close())) .subscribe(message -> { // Process message. . . . Read more