Merge pull request #5 from PandaTechAM/development

scoped service bug fix

Author: mnacmargaryan

src/MassTransit.PostgresOutbox/Jobs/OutboxMessagePublisherService.cs

@@ -17,13 +17,10 @@ internal class OutboxMessagePublisherService<TDbContext> : BackgroundService
         private readonly PeriodicTimer _timer;
         private readonly ILogger<OutboxMessagePublisherService<TDbContext>> _logger;
         private readonly IServiceScopeFactory _serviceScopeFactory;
-        private readonly IPublishEndpoint _publishEndpoint;
 
-        public OutboxMessagePublisherService(IPublishEndpoint publishEndpoint,
-           IServiceScopeFactory serviceScopeFactory,
+        public OutboxMessagePublisherService(IServiceScopeFactory serviceScopeFactory,
            ILogger<OutboxMessagePublisherService<TDbContext>> logger, Settings settings)
         {
-            _publishEndpoint = publishEndpoint;
             _serviceScopeFactory = serviceScopeFactory;
             _logger = logger;
             _timer = new(settings.PublisherTimerPeriod);
@@ -38,6 +35,7 @@ protected override async Task ExecuteAsync(CancellationToken cancellationToken)
 
                 using var scope = _serviceScopeFactory.CreateScope();
                 using var dbContext = scope.ServiceProvider.GetRequiredService<TDbContext>();
+                var publishEndpoint = scope.ServiceProvider.GetRequiredService<IPublishEndpoint>();
                 using var transactionScope = await dbContext.Database.BeginTransactionAsync(System.Data.IsolationLevel.ReadCommitted, cancellationToken);
 
                 try
@@ -64,7 +62,7 @@ protected override async Task ExecuteAsync(CancellationToken cancellationToken)
 
                             var messageObject = JsonConvert.DeserializeObject(message.Payload, type!);
 
-                            await _publishEndpoint.Publish(messageObject!, type!, x => x.Headers.Set(Constants.OutboxMessageId, message.Id), cancellationToken);
+                            await publishEndpoint.Publish(messageObject!, type!, x => x.Headers.Set(Constants.OutboxMessageId, message.Id), cancellationToken);
 
                             publishedMessageIds.Add(message.Id);
                         }

src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj

@@ -8,7 +8,7 @@
         <PackageReadmeFile>Readme.md</PackageReadmeFile>
         <Authors>Pandatech</Authors>
         <Copyright>MIT</Copyright>
-        <Version>1.0.2</Version>
+        <Version>1.0.3</Version>
         <PackageId>Pandatech.MassTransit.PostgresOutbox</PackageId>
         <Title>Pandatech MassTransit PostgreSQL Outbox Extension</Title>
         <PackageTags>Pandatech, library, postgres, distributed systems, microservices, modular monolith, messaging, efcore, mass transit, outbox pattern, inbox pattern</PackageTags>