Copy using Examples . Messaging . MassTransit ;
using MassTransit ;
using Microsoft . Extensions . Configuration ;
using Microsoft . Extensions . DependencyInjection ;
using Microsoft . Extensions . Hosting ;
using RCommon ;
using RCommon . EventHandling ;
using RCommon . EventHandling . Producers ;
using RCommon . MassTransit ;
using RCommon . MassTransit . Producers ;
using System . Diagnostics ;
try
{
var host = Host .CreateDefaultBuilder(args)
.ConfigureAppConfiguration((context , builder) =>
{
ConfigurationContainer . Configuration = builder
.Build();
})
.ConfigureServices(services =>
{
// Configure RCommon
services .AddRCommon()
.WithEventHandling < MassTransitEventHandlingBuilder > (eventHandling =>
{
// This is a wrapper for MassTransit configuration
eventHandling .UsingInMemory((context , cfg) =>
{
cfg .ConfigureEndpoints(context);
});
// A simple and consistent interface for adding producers and subscribers
eventHandling .AddProducer < PublishWithMassTransitEventProducer > ();
eventHandling .AddSubscriber < TestEvent, TestEventHandler > ();
});
services .AddHostedService < Worker > ();
}).Build();
await host .RunAsync();
}
catch ( Exception ex)
{
Console .WriteLine( ex .ToString());
}
Copy protected override async Task ExecuteAsync ( CancellationToken stoppingToken)
{
while ( ! stoppingToken . IsCancellationRequested )
{
Console .WriteLine( "Example Starting" );
var eventProducers = _serviceProvider .GetServices < IEventProducer > ();
var testEvent = new TestEvent ( DateTime . Now , Guid .NewGuid());
foreach ( var producer in eventProducers)
{
Console .WriteLine( $"Producer: {producer}" );
await producer .ProduceEventAsync(testEvent);
}
await Task .Delay( 5000 , stoppingToken);
}
}
Copy using RCommon . EventHandling . Subscribers ;
using System ;
using System . Collections . Generic ;
using System . Diagnostics ;
using System . Linq ;
using System . Text ;
using System . Threading . Tasks ;
namespace Examples . Messaging . MassTransit
{
public class TestEventHandler : ISubscriber < TestEvent >
{
public TestEventHandler ()
{
}
public async Task HandleAsync ( TestEvent notification , CancellationToken cancellationToken = default )
{
Console .WriteLine( "I just handled this event {0}" , new object [] { notification .ToString() });
Console .WriteLine( "Example Complete" );
await Task . CompletedTask ;
}
}
}