FireTransit 1.0.6

FireTransit

FireTransit is a scalable background job processing library that bridges Hangfire, MassTransit, and RabbitMQ to enable distributed job execution in .NET applications.

Features

• Scalability – Distribute job processing across multiple worker nodes.
• Decoupling – Services communicate via messages, reducing direct dependencies.
• Fault Tolerance – RabbitMQ ensures reliable job distribution.
• Easy Integration – Seamlessly connects Hangfire and MassTransit.
• Multi-Database Support – Works with PostgreSQL, SQL Server, and MySQL.

Installation

Add FireTransit to your .NET project:

 dotnet add package FireTransit

Quick Start

1. Configure FireTransit in Program.cs

var builder = Host.CreateApplicationBuilder(args);

// Add FireTransit
builder.Services.UseFireTransit(builder.Configuration);

var host = builder.Build();
host.Run();

2. Consume a Job

public class SendEmailConsumer : IConsumer<SendEmailMessage>
{
 public async Task Consume(ConsumeContext<SendEmailMessage> context)
 {
 Console.WriteLine($"Sending email to {context.Message.Email}");
 }
}

public class SendEmailMessage : IBaseMessage
{
 public string Name => "Sample Email Message";
 public string Description => "Triggers sending email messages.";
 public int Email { get; set; }
}

3. Schedule a recurring job

var eventPublisher = provider.GetRequiredService<IEventPublisher>();

eventPublisher.Recurring<SendEmailMessage>(new SendEmailMessage {
 Email = "user@example.com"
}, Cron.Minutely());

4. Delete a recurring job

Recurring jobs are keyed by the message's Name. Remove one by passing the same message (or its name) used when scheduling:

// By message — uses message.Name as the job key
eventPublisher.RemoveRecurring(new SendEmailMessage());

// Or by name directly
eventPublisher.RemoveRecurring("Sample Email Message");

Removing a job that does not exist is a no-op.

Use Cases

• Email Notifications – Process email-sending jobs asynchronously without blocking the main application.
• Order Processing – Handle background processing of customer orders, reducing API response times.
• Data Importing – Queue large data imports without overloading your API.
• Scheduled Reports – Generate and distribute reports on a schedule.
• Event-Driven Workflows – Trigger automated background tasks based on user actions or system events.

Scaling Up

• Deploy multiple workers to process jobs in parallel.
• Monitor job execution using Hangfire Dashboard.
• Keep services independent for better maintainability.