Skip to content
Permalink
master
Go to file
 
 
Cannot retrieve contributors at this time
24 lines (21 sloc) 746 Bytes
using System.Threading.Tasks;
using Events;
using Identity.Api.Services;
using MassTransit;
namespace Identity.Api.Messaging.Consumers
{
public class ApplicantAppliedEventConsumer : IConsumer<ApplicantAppliedEvent>
{
private readonly IIdentityRepository _identityRepository;
public ApplicantAppliedEventConsumer(IIdentityRepository applicantRepository)
{
_identityRepository = applicantRepository;
}
public async Task Consume(ConsumeContext<ApplicantAppliedEvent> context)
{
// increment the user's application count in the cache
await _identityRepository.UpdateUserApplicationCountAsync(context.Message.ApplicantId.ToString());
}
}
}
You can’t perform that action at this time.