Skip to content

Commit ed5b62b

Browse files
#133: Fix emails was sent separately. (#134)
* [133] Removed untouchable code * [133] Released queue_item for the next contact loop.
1 parent bba2390 commit ed5b62b

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

modules/localgov_workflows_notifications/src/WorkflowNotification.php

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public function enqueue(ContentEntityInterface $entity, string $type): void {
4444

4545
// Ensure the queue contains only one item for per service contact.
4646
$found = FALSE;
47+
$claimed_items = [];
4748
while ($queue_item = $queue->claimItem(1)) {
4849
if ($queue_item->data->service_contact == $contact->id()) {
4950

@@ -58,9 +59,15 @@ public function enqueue(ContentEntityInterface $entity, string $type): void {
5859
$found = TRUE;
5960
break;
6061
}
62+
else {
63+
$claimed_items[] = $queue_item;
64+
}
6165
}
62-
if ($queue_item !== FALSE && !$found) {
63-
$queue->releaseItem($queue_item);
66+
67+
if ($claimed_items) {
68+
foreach ($claimed_items as $queue_item) {
69+
$queue->releaseItem($queue_item);
70+
}
6471
}
6572

6673
if (!$found) {

0 commit comments

Comments
 (0)