Skip to content

Commit 9693f8e

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

File tree

1 file changed

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

1 file changed

+5
-2
lines changed

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -291,12 +291,15 @@ 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 = ' . QueueManagement::MESSAGE_STATUS_TO_BE_DELETED);
294+
->willReturn(
295+
'SELECT message_id FROM queue_message_status WHERE status = ' .
296+
QueueManagement::MESSAGE_STATUS_TO_BE_DELETED);
295297

296298
$connection->expects($this->once())->method('delete')
297299
->with(
298300
$tableNames[1],
299-
'id NOT IN (SELECT message_id FROM queue_message_status WHERE status = ' . QueueManagement::MESSAGE_STATUS_TO_BE_DELETED . ')'
301+
'id NOT IN (SELECT message_id FROM queue_message_status WHERE status = ' .
302+
QueueManagement::MESSAGE_STATUS_TO_BE_DELETED . ')'
300303
)->willReturn(2);
301304
$this->queue->deleteMarkedMessages();
302305
}

0 commit comments

Comments
 (0)