万佳安设备数据
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

3 месяцев назад
3 месяцев назад
3 месяцев назад
12345678910111213141516171819202122232425
  1. using TelpoPush.WanJiaAn.Worker.Handlers;
  2. namespace TelpoPush.WanJiaAn.Worker
  3. {
  4. public class Worker : BackgroundService
  5. {
  6. private readonly ILogger<Worker> _logger;
  7. KafkaSubscribe _kafkaSubscribe;
  8. public Worker(ILogger<Worker> logger, KafkaSubscribe kafkaSubscribe)
  9. {
  10. _logger = logger;
  11. _kafkaSubscribe = kafkaSubscribe;
  12. }
  13. protected override async Task ExecuteAsync(CancellationToken stoppingToken)
  14. {
  15. while (!stoppingToken.IsCancellationRequested)
  16. {
  17. await _kafkaSubscribe.SubscribeAsync();
  18. await Task.Delay(1000, stoppingToken);
  19. }
  20. }
  21. }
  22. }