SWEN3.Paperless.RabbitMq 2.1.2

Star if this works for you — helps others find it.

SWEN3.Paperless.RabbitMq

RabbitMQ messaging library for .NET with SSE support and AI-powered document summarization.

Migration to v2.0.0

// Before (v1.0.4)
services.AddOptionsWithValidateOnStart<GeminiOptions>()
    .BindConfiguration("GenAI:Gemini")
    .ValidateDataAnnotations();
services.AddHttpClient<ITextSummarizer, GeminiService>();
services.AddHostedService<GenAIWorker>();

// After (v2.0.0) - Minimal
services.AddPaperlessGenAI(configuration);

// After (v2.0.0) - With optional validation
services.AddOptionsWithValidateOnStart<GeminiOptions>()
    .BindConfiguration(GeminiOptions.SectionName)
    .ValidateDataAnnotations();
services.AddPaperlessGenAI(configuration);

Breaking Changes:

• Configuration section renamed: GenAI:Gemini → Gemini
• Removed MaxRetries property from GeminiOptions (retry handling now managed by AddStandardResilienceHandler())

Configuration

{
  "RabbitMQ": {
    "Uri": "amqp://guest:guest@localhost:5672"
  }
}

Usage

Basic Setup

// Add RabbitMQ
builder.Services.AddPaperlessRabbitMq(builder.Configuration);

// With SSE support
services.AddPaperlessRabbitMq(config, includeOcrResultStream: true, includeGenAiResultStream: true);

Publishing

var command = new OcrCommand(docId, fileName, storagePath);
await publisher.PublishOcrCommandAsync(command);

var result = new OcrEvent(jobId, "Completed", text, DateTimeOffset.UtcNow);
await publisher.PublishOcrEventAsync(result);

Consuming

await using var consumer = await factory.CreateConsumerAsync<OcrCommand>();

await foreach (var command in consumer.ConsumeAsync(cancellationToken))
{
    try
    {
        // Process message
        await consumer.AckAsync();
    }
    catch
    {
        await consumer.NackAsync(requeue: true);
    }
}

SSE Endpoint

// Map endpoint
app.MapOcrEventStream();

// Client-side
const eventSource = new EventSource('/api/v1/ocr-results');
eventSource.addEventListener('ocr-completed', (event) => {
    const data = JSON.parse(event.data);
    console.log(data);
});

GenAI Support (v2.0.0+)

// Enable GenAI features with RabbitMQ streaming
builder.Services.AddPaperlessRabbitMq(configuration,
    includeOcrResultStream: true,
    includeGenAiResultStream: true);

// Add Gemini document summarization (includes automatic resilience)
builder.Services.AddPaperlessGenAI(configuration);

// Publish GenAI command
var genAiCommand = new GenAICommand(request.JobId, result.Text!);
await _publisher.PublishGenAICommandAsync(genAiCommand);

Configuration:

{
  "Gemini": {
    "ApiKey": "your-api-key",
    "Model": "gemini-2.0-flash",
    "TimeoutSeconds": 30
  }
}

What you get automatically:

• HTTP retry with exponential backoff + jitter (3 attempts)
• Circuit breaker for preventing cascade failures
• Timeout handling per request
• All powered by Microsoft.Extensions.Http.Resilience

Message Types

public record OcrCommand(Guid JobId, string FileName, string FilePath);
public record OcrEvent(Guid JobId, string Status, string? Text, DateTimeOffset ProcessedAt);
public record GenAICommand(Guid DocumentId, string Text);
public record GenAIEvent(Guid DocumentId, string? Summary, DateTimeOffset ProcessedAt, string? ErrorMessage = null);

Installation

dotnet add package SWEN3.Paperless.RabbitMq

License

This project is licensed under the MIT License.