NotiCOO.Core.Consumer 1.0.0

NotiCOO.Core.Consumer

RabbitMQ consumer wrapper library for the NotiCOO notification system.

Overview

This package provides a clean, generic wrapper for RabbitMQ consumer functionality. It abstracts the RabbitMQ implementation details and provides interfaces for message processing that can be implemented by consuming applications.

Features

• Generic message consumer interface (IMessageConsumer)
• RabbitMQ-specific consumer implementation (IRabbitMqConsumer, RabbitMqConsumer)
• Generic message processor interface (IMessageProcessor<T>)
• Base message processor with JSON deserialization (MessageProcessor<T>)
• Dependency injection extensions
• Built-in error handling and logging

Usage

Installation

dotnet add package NotiCOO.Core.Consumer

Basic Setup

using NotiCOO.Core.Consumer.Extensions;
using NotiCOO.Core.Models;

// Configure services
builder.Services.Configure<RabbitMqConfiguration>(
    builder.Configuration.GetSection("RabbitMQ"));

// Add core consumer
builder.Services.AddNotiCOOCoreConsumer();

Creating a Custom Message Processor

using NotiCOO.Core.Consumer.Services;
using NotiCOO.Core.Models;

public class MyNotificationProcessor : MessageProcessor<NotificationMessage>
{
    public MyNotificationProcessor(ILogger<MessageProcessor<NotificationMessage>> logger) 
        : base(logger) { }

    public override async Task<bool> ProcessMessageAsync(NotificationMessage message)
    {
        // Your custom processing logic here
        Logger.LogInformation("Processing notification: {Title}", message.Title);
        
        // Process the message...
        
        return true; // Return success/failure
    }
}

Registering Custom Processors

// Register your custom processor
builder.Services.AddScoped<MyNotificationProcessor>();

// Or use the extension method
builder.Services.AddMessageProcessor<MyNotificationProcessor, NotificationMessage>();

Manual Consumer Usage

public class MyBackgroundService : BackgroundService
{
    private readonly IRabbitMqConsumer _consumer;
    private readonly MyNotificationProcessor _processor;

    public MyBackgroundService(IRabbitMqConsumer consumer, MyNotificationProcessor processor)
    {
        _consumer = consumer;
        _processor = processor;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _consumer.MessageReceived += async (message) =>
        {
            await _processor.ProcessRawMessageAsync(message);
        };

        await _consumer.StartAsync(stoppingToken);
        
        // Keep running...
        await Task.Delay(Timeout.Infinite, stoppingToken);
    }
}

Configuration

Configure RabbitMQ settings in appsettings.json:

{
  "RabbitMQ": {
    "HostName": "localhost",
    "Port": 5672,
    "UserName": "guest",
    "Password": "guest",
    "VirtualHost": "/",
    "ExchangeName": "notifications",
    "QueueName": "notification-queue",
    "RoutingKey": "notification",
    "Durable": true,
    "AutoDelete": false,
    "Exclusive": false,
    "PrefetchCount": 10
  }
}

Interfaces

IMessageConsumer

Generic interface for message consumers.

IRabbitMqConsumer

RabbitMQ-specific consumer interface extending IMessageConsumer.

IMessageProcessor<T>

Generic interface for processing messages of type T.

Dependencies

• NotiCOO.Core
• RabbitMQ.Client
• Microsoft.Extensions.Hosting.Abstractions
• Microsoft.Extensions.Logging.Abstractions
• Microsoft.Extensions.DependencyInjection.Abstractions
• Microsoft.Extensions.Options

NuGet Package

Package ID: NotiCOO.Core.Consumer