From 88e3ebf2cefb0d73b65b2a9284af7b6ce38f5319 Mon Sep 17 00:00:00 2001 From: Deven Shah Date: Wed, 2 Oct 2019 15:59:39 +0100 Subject: [PATCH] ER-1242 Fix issues in processing aggregate message (#838) +semver: patch --- .../AggregateCommunicationComposeQueuePublisher.cs | 2 +- .../Repositories/MongoDbCommunicationRepository.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Communication/Communication.Core/AggregateCommunicationComposeQueuePublisher.cs b/src/Communication/Communication.Core/AggregateCommunicationComposeQueuePublisher.cs index ae33797336..97b171d012 100644 --- a/src/Communication/Communication.Core/AggregateCommunicationComposeQueuePublisher.cs +++ b/src/Communication/Communication.Core/AggregateCommunicationComposeQueuePublisher.cs @@ -8,7 +8,7 @@ namespace Communication.Core { public class AggregateCommunicationComposeQueuePublisher : IAggregateCommunicationComposeQueuePublisher { - private const string QueueName = "communication-messages-composer-queue"; + private const string QueueName = "aggregate-communication-composer-requests-queue"; private readonly string _storageConnectionString; public AggregateCommunicationComposeQueuePublisher(string storageConnectionString) diff --git a/src/Shared/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs b/src/Shared/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs index 0f07f28bda..97dffcce7e 100644 --- a/src/Shared/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs +++ b/src/Shared/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs @@ -62,7 +62,7 @@ public async Task> GetScheduledMessagesSinceAs var filter = builder.Eq(cm => cm.RequestType, requestType) & builder.Eq(cm => cm.Frequency, frequency) & builder.Eq(cm => cm.Status, CommunicationMessageStatus.Pending) & - builder.Gte(cm => cm.RequestDateTime, from); + builder.Gte(cm => cm.RequestDateTime, from) & builder.Lte(cm => cm.RequestDateTime, to); var collection = GetCollection(); var result = await RetryPolicy.ExecuteAsync(_ =>