Found 0 async pipelines for event: "AppCore.Models.Aggregates.Sale.Sale.Events.SalePayBoxCompletedEvent"

[EliveltonRepolho]

Hello, I am just starting a project (EF Core / .Net 6) with Brighter (Version 9.3.3) using In Process (PublishAsync) but when I call the publish method it says no Handlers was found, anyone can help if I am missing some configuration ?

I am following this sample: https://github.com/BrighterCommand/Brighter/tree/master/samples/HelloAsyncListeners

And what I was expecting is running my API, when the event is emitted during the Endpoint call handling, the emitted event would be handled during same time Endpoint handling (I mean not being handled by other process/consumer), not sure if I am miss understanding something on this example too.

Here is my code/configs:

• How I am enabling:

public static IServiceCollection ConfigureBrighter(this IServiceCollection serviceCollection)
  {
    var assemblies = AppDomain.CurrentDomain.GetAssemblies().Where(x => x.FullName!.Contains("AppCore")).ToArray();
    serviceCollection.AddBrighter().AutoFromAssemblies(assemblies);

    return serviceCollection;
  }

• Publishing the Events (I am using DBContext to capture entities with Events - IEntity is mine and holds the Events - that needs to be sent)

public override async Task<int> SaveChangesAsync(CancellationToken cancellationToken = new())
  {
    var entries = ChangeTracker.Entries();
    var result = await base.SaveChangesAsync(cancellationToken);
    await PublishEvents(entries, cancellationToken);
    return result;
  }

  private async Task PublishEvents(IEnumerable<EntityEntry> entityEntries, CancellationToken cancellationToken)
  {
    var mediator = this.GetService<IAmACommandProcessor>();
    var entitiesWithEvents = entityEntries
      .Where(e => e.Entity is IEntity)
      .Select(e => (IEntity)e.Entity)
      .Where(e => e.Events.Any())
      .ToArray();

    foreach (var entity in entitiesWithEvents)
    {
      foreach (var domainEvent in entity.Events.ToArray())
      {
        await mediator.PublishAsync(domainEvent, continueOnCapturedContext: true, cancellationToken: cancellationToken);
      }
    }
  }

• My Event

using Paramore.Brighter;
namespace AppCore.Models.Aggregates.Sale.Sale.Events;

public class SaleCompletedEvent : Event
{
  public Sale Sale { get; private set; }
  public SaleCompletedEvent(Sale sale) : base(Guid.NewGuid())
  {
    Sale = sale;
  }
}

• My Handler

using AppCore.Models.Aggregates.Sale.Sale.Events;
using AppCore.Services;
using Paramore.Brighter;

namespace AppCore.Models.Aggregates.Sale.Sale.Handlers;

public class SaleCompletedUpdateStockHandler : RequestHandlerAsync<SaleCompletedEvent>
{
  private readonly SkuStockService _stockService;
  public SaleCompletedUpdateStockHandler(SkuStockService stockService)
  {
    _stockService = stockService;
  }

  public override async Task<SaleCompletedEvent> HandleAsync(SaleCompletedEvent domainEvent, CancellationToken cancellationToken = default)
  {    
    await _stockService.MoveStockForSale(domainEvent.Sale, cancellationToken);
    return await base.HandleAsync(domainEvent, cancellationToken).ConfigureAwait(ContinueOnCapturedContext);
  }
}

[DevJonny]

Hey @EliveltonRepolho. Would you be able to share your whole solution or link to a repo? What you've posted looks correct so there might be something else, and it's would be easier to debug a full solution.