diff --git a/src/MassTransit.PostgresOutbox/Abstractions/IOutboxDbContext.cs b/src/MassTransit.PostgresOutbox/Abstractions/IOutboxDbContext.cs index bc40a04..fe1bdb8 100644 --- a/src/MassTransit.PostgresOutbox/Abstractions/IOutboxDbContext.cs +++ b/src/MassTransit.PostgresOutbox/Abstractions/IOutboxDbContext.cs @@ -1,10 +1,10 @@ using MassTransit.PostgresOutbox.Entities; using Microsoft.EntityFrameworkCore; -namespace FinHub.Mock1.Box.Abstractions +namespace MassTransit.PostgresOutbox.Abstractions { - public interface IOutboxDbContext - { - public DbSet OutboxMessages { get; set; } - } + public interface IOutboxDbContext + { + public DbSet OutboxMessages { get; set; } + } } diff --git a/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs b/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs index fb6641a..7fe6124 100644 --- a/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs +++ b/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs @@ -1,15 +1,12 @@ using EFCore.PostgresExtensions.Enums; using EFCore.PostgresExtensions.Extensions; -using MassTransit; -using MassTransit.PostgresOutbox; -using MassTransit.PostgresOutbox.Abstractions; using MassTransit.PostgresOutbox.Entities; using MassTransit.PostgresOutbox.Enums; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; -namespace FinHub.Mock1.Box.Abstractions +namespace MassTransit.PostgresOutbox.Abstractions { public abstract class InboxConsumer : IConsumer where TMessage : class diff --git a/src/MassTransit.PostgresOutbox/Extensions/OutboxDbContextExtensions.cs b/src/MassTransit.PostgresOutbox/Extensions/OutboxDbContextExtensions.cs index c38ec52..29483d6 100644 --- a/src/MassTransit.PostgresOutbox/Extensions/OutboxDbContextExtensions.cs +++ b/src/MassTransit.PostgresOutbox/Extensions/OutboxDbContextExtensions.cs @@ -1,10 +1,10 @@ -using FinHub.Mock1.Box.Abstractions; +using MassTransit.PostgresOutbox.Abstractions; using MassTransit.PostgresOutbox.Entities; using Newtonsoft.Json; namespace MassTransit.PostgresOutbox.Extensions { - public static class OutboxDbContextExtensions + public static class OutboxDbContextExtensions { public static Guid AddToOutbox(this IOutboxDbContext dbContext, T message) { diff --git a/src/MassTransit.PostgresOutbox/Extensions/ServiceCollectionExtensions.cs b/src/MassTransit.PostgresOutbox/Extensions/ServiceCollectionExtensions.cs index f45a7aa..6d3ae42 100644 --- a/src/MassTransit.PostgresOutbox/Extensions/ServiceCollectionExtensions.cs +++ b/src/MassTransit.PostgresOutbox/Extensions/ServiceCollectionExtensions.cs @@ -1,5 +1,4 @@ -using FinHub.Mock1.Box.Abstractions; -using MassTransit.PostgresOutbox.Abstractions; +using MassTransit.PostgresOutbox.Abstractions; using MassTransit.PostgresOutbox.Jobs; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; diff --git a/src/MassTransit.PostgresOutbox/Jobs/OutboxMessagePublisherService.cs b/src/MassTransit.PostgresOutbox/Jobs/OutboxMessagePublisherService.cs index 4b4b4a4..336c7e4 100644 --- a/src/MassTransit.PostgresOutbox/Jobs/OutboxMessagePublisherService.cs +++ b/src/MassTransit.PostgresOutbox/Jobs/OutboxMessagePublisherService.cs @@ -1,7 +1,6 @@ using EFCore.PostgresExtensions.Enums; using EFCore.PostgresExtensions.Extensions; -using FinHub.Mock1.Box.Abstractions; -using MassTransit; +using MassTransit.PostgresOutbox.Abstractions; using MassTransit.PostgresOutbox.Enums; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; diff --git a/src/MassTransit.PostgresOutbox/Jobs/OutboxMessageRemovalService.cs b/src/MassTransit.PostgresOutbox/Jobs/OutboxMessageRemovalService.cs index cc8c0ff..0cf0c6b 100644 --- a/src/MassTransit.PostgresOutbox/Jobs/OutboxMessageRemovalService.cs +++ b/src/MassTransit.PostgresOutbox/Jobs/OutboxMessageRemovalService.cs @@ -1,5 +1,5 @@ -using FinHub.Mock1.Box.Abstractions; -using MassTransit.PostgresOutbox; +using MassTransit.PostgresOutbox; +using MassTransit.PostgresOutbox.Abstractions; using MassTransit.PostgresOutbox.Enums; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; @@ -8,7 +8,7 @@ namespace MassTransit.PostgresOutbox.Jobs { - internal class OutboxMessageRemovalService : BackgroundService + internal class OutboxMessageRemovalService : BackgroundService where TDbContext : DbContext, IOutboxDbContext { private readonly int _beforeInDays;