Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions src/MassTransit.PostgresOutbox/Abstractions/IOutboxDbContext.cs
Original file line number Diff line number Diff line change
@@ -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<OutboxMessage> OutboxMessages { get; set; }
}
public interface IOutboxDbContext
{
public DbSet<OutboxMessage> OutboxMessages { get; set; }
}
}
5 changes: 1 addition & 4 deletions src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs
Original file line number Diff line number Diff line change
@@ -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<TMessage, TDbContext> : IConsumer<TMessage>
where TMessage : class
Expand Down
Original file line number Diff line number Diff line change
@@ -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<T>(this IOutboxDbContext dbContext, T message)
{
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand All @@ -8,7 +8,7 @@

namespace MassTransit.PostgresOutbox.Jobs
{
internal class OutboxMessageRemovalService<TDbContext> : BackgroundService
internal class OutboxMessageRemovalService<TDbContext> : BackgroundService
where TDbContext : DbContext, IOutboxDbContext
{
private readonly int _beforeInDays;
Expand Down