Browse Source

Merge pull request #2466 from abpframework/maliming/remove-sync-method

Remove the sync method for background job module.
pull/2470/head
Halil İbrahim Kalkan 7 years ago
committed by GitHub
parent
commit
ae0abe3cbe
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
  1. 7
      modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobStore.cs
  2. 2
      modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/IBackgroundJobRepository.cs
  3. 6
      modules/background-jobs/src/Volo.Abp.BackgroundJobs.EntityFrameworkCore/Volo/Abp/BackgroundJobs/EntityFrameworkCore/EfCoreBackgroundJobRepository.cs
  4. 6
      modules/background-jobs/src/Volo.Abp.BackgroundJobs.MongoDB/Volo/Abp/BackgroundJobs/MongoDB/MongoBackgroundJobRepository.cs

7
modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobStore.cs

@ -34,13 +34,6 @@ namespace Volo.Abp.BackgroundJobs
); );
} }
public List<BackgroundJobInfo> GetWaitingJobs(int maxResultCount)
{
return ObjectMapper.Map<List<BackgroundJobRecord>, List<BackgroundJobInfo>>(
BackgroundJobRepository.GetWaitingList(maxResultCount)
);
}
public virtual async Task<List<BackgroundJobInfo>> GetWaitingJobsAsync(int maxResultCount) public virtual async Task<List<BackgroundJobInfo>> GetWaitingJobsAsync(int maxResultCount)
{ {
return ObjectMapper.Map<List<BackgroundJobRecord>, List<BackgroundJobInfo>>( return ObjectMapper.Map<List<BackgroundJobRecord>, List<BackgroundJobInfo>>(

2
modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/IBackgroundJobRepository.cs

@ -7,8 +7,6 @@ namespace Volo.Abp.BackgroundJobs
{ {
public interface IBackgroundJobRepository : IBasicRepository<BackgroundJobRecord, Guid> public interface IBackgroundJobRepository : IBasicRepository<BackgroundJobRecord, Guid>
{ {
List<BackgroundJobRecord> GetWaitingList(int maxResultCount);
Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount); Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount);
} }
} }

6
modules/background-jobs/src/Volo.Abp.BackgroundJobs.EntityFrameworkCore/Volo/Abp/BackgroundJobs/EntityFrameworkCore/EfCoreBackgroundJobRepository.cs

@ -21,12 +21,6 @@ namespace Volo.Abp.BackgroundJobs.EntityFrameworkCore
Clock = clock; Clock = clock;
} }
public List<BackgroundJobRecord> GetWaitingList(int maxResultCount)
{
return GetWaitingListQuery(maxResultCount)
.ToList();
}
public async Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount) public async Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount)
{ {
return await GetWaitingListQuery(maxResultCount) return await GetWaitingListQuery(maxResultCount)

6
modules/background-jobs/src/Volo.Abp.BackgroundJobs.MongoDB/Volo/Abp/BackgroundJobs/MongoDB/MongoBackgroundJobRepository.cs

@ -21,12 +21,6 @@ namespace Volo.Abp.BackgroundJobs.MongoDB
Clock = clock; Clock = clock;
} }
public List<BackgroundJobRecord> GetWaitingList(int maxResultCount)
{
return GetWaitingListQuery(maxResultCount)
.ToList();
}
public async Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount) public async Task<List<BackgroundJobRecord>> GetWaitingListAsync(int maxResultCount)
{ {
return await GetWaitingListQuery(maxResultCount) return await GetWaitingListQuery(maxResultCount)

Loading…
Cancel
Save