ER-1242 Fix issues in processing aggregate message (#838) +semver: patch

SkillsFundingAgency · Oct 2, 2019 · 88e3ebf · 88e3ebf
1 parent 7a8587c
commit 88e3ebf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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/...ed/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs b/...ed/Recruit.Vacancies.Client/Infrastructure/Repositories/MongoDbCommunicationRepository.cs
@@ -62,7 +62,7 @@ public async Task<IEnumerable<CommunicationMessage>> 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<CommunicationMessage>();
             var result = await RetryPolicy.ExecuteAsync(_ =>