Browse Source

Enable nullable annotations

pull/17109/head
liangshiwei 3 years ago
parent
commit
faf581920e
  1. 2
      framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs
  2. 4
      framework/src/Volo.Abp.HangFire/Volo/Abp/Hangfire/AbpHangfireBackgroundJobServer.cs
  3. 4
      framework/src/Volo.Abp.HangFire/Volo/Abp/Hangfire/AbpHangfireOptions.cs

2
framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs

@ -180,7 +180,7 @@ public class JobQueue<TArgs> : IJobQueue<TArgs>
exchange: "",
routingKey: routingKey,
basicProperties: basicProperties,
body: Serializer.Serialize(args)
body: Serializer.Serialize(args!)
);
return Task.CompletedTask;

4
framework/src/Volo.Abp.HangFire/Volo/Abp/Hangfire/AbpHangfireBackgroundJobServer.cs

@ -4,9 +4,9 @@ namespace Volo.Abp.Hangfire;
public class AbpHangfireBackgroundJobServer
{
public BackgroundJobServer HangfireJobServer { get; }
public BackgroundJobServer? HangfireJobServer { get; }
public AbpHangfireBackgroundJobServer(BackgroundJobServer hangfireJobServer)
public AbpHangfireBackgroundJobServer(BackgroundJobServer? hangfireJobServer)
{
HangfireJobServer = hangfireJobServer;
}

4
framework/src/Volo.Abp.HangFire/Volo/Abp/Hangfire/AbpHangfireOptions.cs

@ -19,11 +19,11 @@ public class AbpHangfireOptions
public JobStorage? Storage { get; set; }
[NotNull]
public Func<IServiceProvider, BackgroundJobServer> BackgroundJobServerFactory {
public Func<IServiceProvider, BackgroundJobServer?> BackgroundJobServerFactory {
get => _backgroundJobServerFactory;
set => _backgroundJobServerFactory = Check.NotNull(value, nameof(value));
}
private Func<IServiceProvider, BackgroundJobServer> _backgroundJobServerFactory;
private Func<IServiceProvider, BackgroundJobServer?> _backgroundJobServerFactory;
public AbpHangfireOptions()
{

Loading…
Cancel
Save