Hocam selam,
Metrobus , UseMessageSchedulerWithQuartz methodunı nasıl kullanıp ayarlanıyor?
methodun aldığı parametreye göre ;
services.AddMetroBus(x => x.AddConsumer<WorkerConsumer>());
services.AddSingleton(provider => MetroBusInitializer.Instance
.UseRabbitMq(mqConstant.RabbitMQUri, mqConstant.RabbitMQUserName, mqConstant.RabbitMQPassword)
.RegisterConsumer<WorkerConsumer>("ilan.schedule.queue", provider)
.UseMessageSchedulerWithQuartz("rabbitmq://localhost/quartz")
.SetPrefetchCount(16)
.UseRateLimiter(20, TimeSpan.FromMinutes(10.0))
.Build())
.BuildServiceProvider();
services.AddHostedService<BusService>();
biçimde ayarladım
consumer ;
public class WorkerConsumer : IConsumer<WorkerCommand>
{
private readonly ILogger<WorkerConsumer> Logger;
readonly Uri NotificationService;
public WorkerConsumer(ILogger<WorkerConsumer> logger)
{
Logger = logger;
NotificationService = new Uri("rabbitmq://localhost/notification.queue");
}
public Task Consume(ConsumeContext<WorkerCommand> context)
{
var IlanId = context.Message.IlanId;
var EstimateDate = context.Message.EstimateDate;
context.ScheduleSend(NotificationService, EstimateDate, new NotifyCommand
{
IlanId = IlanId
});
return Task.CompletedTask;
}
}
}
çalıştırdıktan sonra estime tarihinde işlem yapmıyor.
Hocam selam,
Metrobus , UseMessageSchedulerWithQuartz methodunı nasıl kullanıp ayarlanıyor?
methodun aldığı parametreye göre ;
biçimde ayarladım
consumer ;
çalıştırdıktan sonra estime tarihinde işlem yapmıyor.