Skip to content

Commit 0b6ba28

Browse files
committed
chore: Adjust parameter names and comments
1 parent 28a0c1a commit 0b6ba28

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/BuildingBlocks/Dispatcher/Masa.BuildingBlocks.Dispatcher.IntegrationEvents/Logs/IIntegrationEventLogService.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -10,13 +10,13 @@ public interface IIntegrationEventLogService
1010
/// </summary>
1111
/// <param name="retryBatchSize">The size of a single event to be retried</param>
1212
/// <param name="maxRetryTimes"></param>
13-
/// <param name="minimumRetryInterval">minimum retry interval (unit: s)</param>
13+
/// <param name="minimum">minimum retry interval (unit: s)</param>
1414
/// <param name="cancellationToken"></param>
1515
/// <returns></returns>
1616
Task<IEnumerable<IntegrationEventLog>> RetrieveEventLogsFailedToPublishAsync(
1717
int retryBatchSize,
1818
int maxRetryTimes,
19-
int minimumRetryInterval,
19+
int minimum,
2020
CancellationToken cancellationToken = default);
2121

2222
/// <summary>

src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents.EventLogs.EFCore/IntegrationEventLogService.cs

+4-4
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public async Task<IEnumerable<IntegrationEventLog>> RetrieveEventLogsFailedToPub
4040
.Where(e => (e.State == IntegrationEventStates.PublishedFailed || e.State == IntegrationEventStates.InProgress) &&
4141
e.TimesSent <= maxRetryTimes &&
4242
e.ModificationTime < time)
43-
.OrderBy(o => o.CreationTime)
43+
.OrderBy(e => e.CreationTime)
4444
.Take(retryBatchSize)
4545
.ToListAsync(cancellationToken);
4646

@@ -49,7 +49,7 @@ public async Task<IEnumerable<IntegrationEventLog>> RetrieveEventLogsFailedToPub
4949
_eventTypes ??= _serviceProvider.GetRequiredService<IIntegrationEventBus>().GetAllEventTypes()
5050
.Where(type => typeof(IIntegrationEvent).IsAssignableFrom(type));
5151

52-
return result.OrderBy(o => o.CreationTime)
52+
return result.OrderBy(e => e.CreationTime)
5353
.Select(e => e.DeserializeJsonContent(_eventTypes.First(t => t.Name == e.EventTypeShortName)));
5454
}
5555

@@ -68,15 +68,15 @@ public async Task<IEnumerable<IntegrationEventLog>> RetrieveEventLogsPendingToPu
6868
{
6969
var result = await _eventLogContext.EventLogs
7070
.Where(e => e.State == IntegrationEventStates.NotPublished)
71-
.OrderBy(o => o.CreationTime)
71+
.OrderBy(e => e.CreationTime)
7272
.Take(batchSize)
7373
.ToListAsync(cancellationToken);
7474
if (result.Any())
7575
{
7676
_eventTypes ??= _serviceProvider.GetRequiredService<IIntegrationEventBus>().GetAllEventTypes()
7777
.Where(type => typeof(IIntegrationEvent).IsAssignableFrom(type));
7878

79-
return result.OrderBy(o => o.CreationTime)
79+
return result.OrderBy(e => e.CreationTime)
8080
.Select(e => e.DeserializeJsonContent(_eventTypes.First(t => t.Name == e.EventTypeShortName)));
8181
}
8282

0 commit comments

Comments
 (0)