Tag: MASSTRANSIT
Estoy utilizando MassTransit en un proyecto con AmazonSQS y desde que actualicé los paquetes a la última versión 7.3, estoy obteniendo esta excepción: —> Amazon.SimpleNotificationService.AmazonSimpleNotificationServiceException: Límite superado —> Amazon.Runtime.Internal.HttpErrorResponseException: Se produjo una excepción del tipo ‘Amazon.Runtime.Internal.HttpErrorResponseException’. A veces, la excepción proviene de SQS; lo que sucede es que cuando estaba . . . Read more
En este post encontré cómo enviar mis propiedades de enriquecimiento de Serilog a los consumidores. Cuando registro mis informaciones, todo está correcto. Pero cuando se produce una excepción en los consumidores, no veo mis propiedades de Serilog en el archivo de registro, como puede ver: ERR – – – 2022-01-03 . . . Read more
El error es: ConfigurationException: Ya se agregó un punto de recepción con la misma clave: Events Tengo appsettings.Development.json con “EventsBusOptions”: { “HostUri”: “rabbimq://rabbitmq.test.com/gate”, “UserName”: “xxx”, “Password”: “xxxxxx”, “QueueName”: “events”, // <<< si cambio el nombre de la cola a cualquier otra cadena, por ejemplo “events1”, NO hay error “PrefetchCount”: 16, . . . Read more
Estoy leyendo sobre el Límite de Concurrencia en MassTransit RabbitMQ, pero aún no entiendo cómo funciona realmente. Supongamos que tengo 4 consumidores y configuro las colas con un límite de concurrencia de 1 config.UseConcurrencyLimit(1);. Cuando un productor envía 4 mensajes al mismo tiempo, ¿qué sucederá? ¿Se consumirá solo uno de . . . Read more
Estoy tratando de hacer pruebas de integración contra un Comando de MediatR cuyo controlador depende de un IRequestClient inyectado en su constructor. public class SayHelloCommand : IRequest<string> { } public class SayHelloCommandHandler : IRequestHandler<SayHelloCommand, string> { private readonly IRequestClient<IGetProfileMessageResult> _profileClient; public SayHelloCommandHandler(IRequestClient<IGetProfileMessageResult> profileClient) { _profileClient = profileClient; } public async . . . Read more