Skip to content

Commit 6193247

Browse files
committed
MC-5588: When using MysqlMQ messages are always set to complete even if exception occurs
- Fix static tests
1 parent 7465036 commit 6193247

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

app/code/Magento/MysqlMq/Model/Driver/Queue.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,11 +110,13 @@ public function subscribe($callback)
110110
while (true) {
111111
while ($envelope = $this->dequeue()) {
112112
try {
113+
// phpcs:ignore Magento2.Functions.DiscouragedFunction
113114
call_user_func($callback, $envelope);
114115
} catch (\Exception $e) {
115116
$this->reject($envelope);
116117
}
117118
}
119+
// phpcs:ignore Magento2.Functions.DiscouragedFunction
118120
sleep($this->interval);
119121
}
120122
}

dev/tests/integration/testsuite/Magento/Framework/MessageQueue/_files/valid_queue_input.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,11 @@
2323
"name" => "publisher5.topic",
2424
"schema" => [
2525
"schema_type" => "object",
26-
"schema_value" => "Magento\\TestModuleMysqlMq\\Model\\DataObject"
26+
"schema_value" => Magento\TestModuleMysqlMq\Model\DataObject::class
2727
],
2828
"response_schema" => [
2929
"schema_type" => "object",
30-
"schema_value" => "Magento\\Customer\\Api\\Data\\CustomerInterface"
30+
"schema_value" => \Magento\Customer\Api\Data\CustomerInterface::class
3131
],
3232
"publisher" => "test-publisher-5"
3333
]

0 commit comments

Comments
 (0)