Масстранзит - явка с потребителем - PullRequest
Новая
       44

Масстранзит - явка с потребителем

0 голосов
/ 28 апреля 2020

У меня есть длительное поколение PDF в составе SAGA, поэтому я прочитал о явке и пытаюсь ее использовать. Однако у меня сложный потребитель - несколько обращений к БД, зависимость от стороннего сервиса для создания PDF и т. Д. c. У меня проблемы с поиском хорошего примера того, как именно мне следует использовать конечную точку явки.

Мое текущее использование: 

c.TurnoutEndpoint<PdfGenerationCommand>(host, "pdf-generation-TURNOUT", e =>
            {
                e.SuperviseInterval = TimeSpan.FromSeconds(30);
                e.SetJobFactory(async context =>
                {
                    var consumer = container.GetInstance<PdfGenerationCommandConsumer>();
                    var sw = new Stopwatch();
                    sw.Start();

                    Console.WriteLine($"{DateTime.Now} - [PdfGenerationCommand] Job started!");
                    await consumer.Consume(context.Command).ConfigureAwait(false);
                    sw.Stop();
                    Console.WriteLine($"{DateTime.Now} - [PdfGenerationCommand] Job finished in {sw.ElapsedMilliseconds}!");
                });
            });

Однако сообщения попадают в очередь _skipped. Я делаю что-то не так и не вижу этого

...