Compare commits

..

No commits in common. "c1bd5e6cfbe445ad93e0e542815809acad97d9b9" and "3178b031e4763ff4ee6342c82c247ea477215d57" have entirely different histories.

3 changed files with 0 additions and 45 deletions

View File

@ -11,6 +11,4 @@ public interface IMgSessionService<TSessionItem> where TSessionItem : IMgSession
public bool TryGetSessionItem(string sessionId, out TSessionItem sessionItem);
public bool TryRemoveSessionItem(string sessionId, out TSessionItem sessionItem);
public int Count();
bool TryGetSessionItemBySignlaRConnectionId(string signalRConnectionId, out TSessionItem? sessionItem);
}

View File

@ -1,37 +0,0 @@
using Microsoft.Extensions.Hosting;
using Nop.Services.Logging;
namespace Mango.Nop.Services;
public abstract class MgBackgroundServiceBase(ILogger logger, IServiceProvider service) : BackgroundService
{
protected abstract Task OnExecuteAsync();
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
while (!stoppingToken.IsCancellationRequested)
{
try
{
await logger.InformationAsync($"MgBackgroundServiceBase.ExecuteAsync(); Processing ExecuteAsync");
await OnExecuteAsync();
}
catch (Exception ex)
{
await logger.ErrorAsync($"MgBackgroundServiceBase.ExecuteAsync(); Failure while processing ExecuteAsync", ex, null);
}
}
}
public override async Task StartAsync(CancellationToken cancellationToken)
{
await logger.InformationAsync("MgBackgroundServiceBase.ExecuteAsync(); Starting MgBackgroundServiceBase");
await base.StartAsync(cancellationToken);
}
public override async Task StopAsync(CancellationToken cancellationToken)
{
await logger.InformationAsync("MgBackgroundServiceBase.StopAsync(); Stopping MgBackgroundServiceBase");
await base.StopAsync(cancellationToken);
}
}

View File

@ -37,10 +37,4 @@ public abstract class MgSessionService<TSessionItem> : IMgSessionService<TSessio
}
public int Count() => Sessions.Count;
public bool TryGetSessionItemBySignlaRConnectionId(string signalRConnectionId, out TSessionItem? sessionItem)
{
sessionItem = Sessions.Values.FirstOrDefault(x => x.SignaRConnectionId == signalRConnectionId);
return sessionItem != null;
}
}