Skip to content

Commit 9dc86b9

Browse files
committed
ACP2E-3387: [Cloud] Magento: queue message has been deleted
1 parent bccc98e commit 9dc86b9

File tree

1 file changed

+2
-2
lines changed
  • app/code/Magento/MysqlMq/Test/Unit/Model/ResourceModel

1 file changed

+2
-2
lines changed

app/code/Magento/MysqlMq/Test/Unit/Model/ResourceModel/QueueTest.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -291,12 +291,12 @@ function ($arg1, $arg2) use ($tableNames) {
291291
$select->expects($this->once())->method('distinct')->willReturnSelf();
292292
$select->expects($this->once())
293293
->method('assemble')
294-
->willReturn('SELECT message_id FROM queue_message_status WHERE status = 7');
294+
->willReturn('SELECT message_id FROM queue_message_status WHERE status = ' . QueueManagement::MESSAGE_STATUS_TO_BE_DELETED);
295295

296296
$connection->expects($this->once())->method('delete')
297297
->with(
298298
$tableNames[1],
299-
'id NOT IN (SELECT message_id FROM queue_message_status WHERE status = 7)'
299+
'id NOT IN (SELECT message_id FROM queue_message_status WHERE status = ' . QueueManagement::MESSAGE_STATUS_TO_BE_DELETED . ')'
300300
)->willReturn(2);
301301
$this->queue->deleteMarkedMessages();
302302
}

0 commit comments

Comments
 (0)