abp/framework/test/Volo.Abp.EventBus.Tests/Volo/Abp/EventBus/Distributed/MySimpleDistributedSingleInstanceEventHandler.cs

using System;
using System.Threading.Tasks;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Entities.Events.Distributed;
using Volo.Abp.MultiTenancy;

namespace Volo.Abp.EventBus.Distributed
{
    public class MySimpleDistributedSingleInstanceEventHandler : IDistributedEventHandler<MySimpleEventData>, IDistributedEventHandler<EntityCreatedEto<MySimpleEventData>>, ITransientDependency
    {
        private readonly ICurrentTenant _currentTenant;

        public MySimpleDistributedSingleInstanceEventHandler(ICurrentTenant currentTenant)
        {
            _currentTenant = currentTenant;
        }

        public static Guid? TenantId { get; set; }

        public Task HandleEventAsync(MySimpleEventData eventData)
        {
            TenantId = _currentTenant.Id;
            return Task.CompletedTask;
        }

        public Task HandleEventAsync(EntityCreatedEto<MySimpleEventData> eventData)
        {
            TenantId = _currentTenant.Id;
            return Task.CompletedTask;
        }
    }
}