Skip to content

Commit

Permalink
rename file; update dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
ardalis committed May 3, 2021
1 parent eb3c644 commit 5641335
Show file tree
Hide file tree
Showing 3 changed files with 39 additions and 5 deletions.
5 changes: 1 addition & 4 deletions FrontDesk/src/FrontDesk.Api/Endpoints/Appointment/Create.cs
Original file line number Diff line number Diff line change
Expand Up @@ -21,19 +21,16 @@ public class Create : BaseAsyncEndpoint
.WithResponse<CreateAppointmentResponse>
{
private readonly IRepository<Schedule> _scheduleRepository;
private readonly IReadRepository<Schedule> _scheduleReadRepository;
private readonly IReadRepository<AppointmentType> _appointmentTypeReadRepository;
private readonly IMapper _mapper;
private readonly ILogger<Create> _logger;

public Create(IRepository<Schedule> scheduleRepository,
IReadRepository<Schedule> scheduleReadRepository,
IReadRepository<AppointmentType> appointmentTypeReadRepository,
IMapper mapper,
ILogger<Create> logger)
{
_scheduleRepository = scheduleRepository;
_scheduleReadRepository = scheduleReadRepository;
_appointmentTypeReadRepository = appointmentTypeReadRepository;
_mapper = mapper;
_logger = logger;
Expand All @@ -52,7 +49,7 @@ public override async Task<ActionResult<CreateAppointmentResponse>> HandleAsync(
var response = new CreateAppointmentResponse(request.CorrelationId());

var spec = new ScheduleByIdWithAppointmentsSpec(request.ScheduleId); // TODO: Just get that day's appointments
var schedule = await _scheduleReadRepository.GetBySpecAsync(spec);
var schedule = await _scheduleRepository.GetBySpecAsync(spec);

var appointmentType = await _appointmentTypeReadRepository.GetByIdAsync(request.AppointmentTypeId);
var appointmentStart = request.DateOfAppointment;
Expand Down
39 changes: 38 additions & 1 deletion VetClinicPublic/src/VetClinicPublic/FrontDeskRabbitMqService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,16 @@ private void InitializeConnection(RabbitMqConfiguration settings)
}
}











protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
stoppingToken.ThrowIfCancellationRequested();
Expand All @@ -88,15 +98,42 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken)

return Task.CompletedTask;
}














private async void OnMessageReceived(object model, BasicDeliverEventArgs args)
{
var body = args.Body.ToArray();
var message = Encoding.UTF8.GetString(body);
//_logger.LogInformation(" [x] Received {0}", message);

await HandleMessage(message);
}















private async Task HandleMessage(string message)
{
_logger.LogInformation($"Handling Message: {message}");
Expand Down

0 comments on commit 5641335

Please sign in to comment.