Infrastructure.Messaging

Library for messaging between services.

Builds

	Travis
Infrastructure.Messaging

Installation

Packages	Travis
Infrastructure.Messaging
Infrastructure.Messaging.DependencyInjection
Infrastructure.Messaging.RabbitMQ
Infrastructure.Messaging.InMemory

Requirements

• .NETStandard 2.1
• Microsoft.Extensions.DependencyInjection (>= 3.0.0)
• Microsoft.Extensions.Logging.Abstractions (>= 3.0.0)
• System.Text.Json (>= 4.6.0)

Demo

How to

Register Messaging via .AddMessaging() extension method provided by Infrastructure.Messaging.Extensions.DependencyInjection package.

var rabbitMQUri = configuration.GetSection("RabbitMq")["uri"];

var serviceProvider = 
    new ServiceCollection()
        .AddLogging(lb => lb.AddConsole())
        .AddMessaging(mc =>
            {
                mc.UseRabbitMQ(cf => cf.Uri = new Uri(rabbitMQUri));
                mc.UseJsonPacker(jso => jso.PropertyNamingPolicy = JsonNamingPolicy.CamelCase);
            }, 
            sc => sc
                .AddSingleton<IMessageHandler<TestMessage>, TestMessageHandler>()
                .AddSingleton<IMessageHandler<TestMessageWithEventId>, TestMessageHandler>()
        )
    .BuildServiceProvider();

Implement handlers.

public sealed class TestMessageHandler : 
    IMessageHandler<TestMessage>,
    IMessageHandler<TestMessageWithEventId>
{
    private readonly ILogger<TestMessageHandler> _logger;

    public TestMessageHandler(ILogger<TestMessageHandler> logger)
    {
        _logger = logger;
    }

    public async Task Handle(TestMessage message, CancellationToken cancellationToken)
    {
        await Task.Delay(100);
        _logger.LogInformation("Test message was dispached {message}", message.Ping);
        throw new Exception("AASDSD");
    }

    public Task Handle(TestMessageWithEventId message, CancellationToken cancellationToken)
    {
        _logger.LogInformation("TestMessageWithEventId was dispatched. {eventId}, {text}", message.EventId, message.Text);
        return Task.CompletedTask;
    }
}

Use IMessageRouter.Route() to start the routing process and IMessagePublisher.Publish(IMessage message) to publish a message.

public async Task Main()
{
    CancellationTokenSource = new CancellationTokenSource();

	//..
    MessageRouter = serviceProvider.GetRequiredService<IMessageRouter>();
    Publisher = serviceProvider.GetRequiredService<IMessagePublisher>();
	//..

	await Publisher.Publish(new TestMessage { Ping = "A" }, cancellationToken: CancellationTokenSource.Token);
	
	// ..
	await MessageRouter.Route(cancellationToken: CancellationTokenSource.Token);
}