Parcourir la source

Cron for deleting messages

master
radivoje.milutinovic il y a 3 ans
Parent
révision
00ad4af823

+ 1
- 2
SecureSharing/Program.cs Voir le fichier

services.AddScoped<MessageDeletionJob>(); services.AddScoped<MessageDeletionJob>();
services.AddSingleton(new JobMetadata( services.AddSingleton(new JobMetadata(
typeof(MessageDeletionJob), typeof(MessageDeletionJob),
"0 0 12 * * ?"));

"0 0 01 * * ?"));


services.AddHostedService<JobsService>(); services.AddHostedService<JobsService>();



+ 4
- 2
SecureSharing/Quartz/JobFactory.cs Voir le fichier



public class JobFactory : IJobFactory public class JobFactory : IJobFactory
{ {
protected readonly ConcurrentDictionary<IJob, IServiceScope> _scopes = new();
protected readonly IServiceProvider _serviceProvider;
private readonly ConcurrentDictionary<IJob, IServiceScope> _scopes = new();
private readonly IServiceProvider _serviceProvider;


public JobFactory(IServiceProvider serviceProvider) public JobFactory(IServiceProvider serviceProvider)
{ {
public void ReturnJob(IJob job) public void ReturnJob(IJob job)
{ {
if (_scopes.TryRemove(job, out var scope)) if (_scopes.TryRemove(job, out var scope))
{
// The Dispose() method ends the scope lifetime. // The Dispose() method ends the scope lifetime.
// Once Dispose is called, any scoped services that have been resolved from ServiceProvider will be disposed. // Once Dispose is called, any scoped services that have been resolved from ServiceProvider will be disposed.
scope.Dispose(); scope.Dispose();
}
} }
} }

+ 0
- 2
SecureSharing/Quartz/JobMetadata.cs Voir le fichier

public JobMetadata(Type jobType, public JobMetadata(Type jobType,
string cronExpression) string cronExpression)
{ {
//JobId = Id;
JobType = jobType; JobType = jobType;
//JobName = jobName;
CronExpression = cronExpression; CronExpression = cronExpression;
} }



Chargement…
Annuler
Enregistrer