Rebus: Trigger event handlers twice

[realLiangshiwei]

Related to: rebus-org/Rebus.ServiceProvider#50

[brunobertechini]

Hello there, I just created a new solution (5.2.2) and added the configuration for Rebus.RabbitMq to test the integration.

I am facing the same issue of my handler being called twice when using Rebus+RabbitMq.

I have no special configuration. A simple event and a simple handler:

PreConfigure<AbpRebusEventBusOptions>(options =>
        {
            var queueName = "eventbus";
            options.InputQueueName = queueName;
            options.Configurer = rebusConfigurer =>
            {
                rebusConfigurer.Transport(t => t.UseRabbitMq("amqp://localhost", queueName));
                // rebusConfigurer.Subscriptions(s => s.UseJsonFile(@"subscriptions.json"));
            };
        });

public class SampleEvent1 : IEvent
{
    [Required]
    public string MyStringProp { get; set; }
    
    [Required]
    public int? MyIntProp { get; set; }
    
    [Required]
    public bool? MyBoolProp { get; set; }
    
    [Required]
    public DateTime? MyDateTimeProp { get; set; }
}

public class SampleEvent1Handler : IDistributedEventHandler<SampleEvent1>, ITransientDependency
{
    private readonly ILogger<SampleEvent1Handler> _logger;
    private readonly IDistributedEventBus _bus;

    public SampleEvent1Handler(ILogger<SampleEvent1Handler> logger, IDistributedEventBus bus)
    {
        _logger = logger;
        _bus = bus;
    }    
    
    public Task HandleEventAsync(SampleEvent1 eventData)
    {
        _logger.LogInformation($"Received Event {eventData.GetType().FullName}");

        var a = _bus;
        
        Thread.Sleep(10000);
        
        _logger.LogInformation($"Finished processing Event {eventData.GetType().FullName}");
        
        return Task.CompletedTask;
    }
}