File tree Expand file tree Collapse file tree 1 file changed +5
-9
lines changed
dev/tests/integration/testsuite/Magento/MysqlMq/Model Expand file tree Collapse file tree 1 file changed +5
-9
lines changed Original file line number Diff line number Diff line change @@ -185,17 +185,13 @@ public function testMessageRetry()
185
185
$ messages = $ this ->queueManagement ->readMessages ('queue1 ' , 1 );
186
186
$ message = array_shift ($ messages );
187
187
$ messageRelationId = $ message [QueueManagement::MESSAGE_QUEUE_RELATION_ID ];
188
- $ this ->queueManagement ->pushToQueueForRetry ($ messageRelationId );
189
188
190
- $ retryMessage = null ;
191
- for ($ i = 1 ; $ i <= 3 ; $ i ++) {
189
+ for ($ i = 0 ; $ i < 2 ; $ i ++) {
190
+ $ this ->assertEquals ($ i , $ message [QueueManagement::MESSAGE_NUMBER_OF_TRIALS ]);
191
+ $ this ->queueManagement ->pushToQueueForRetry ($ message [QueueManagement::MESSAGE_QUEUE_RELATION_ID ]);
192
192
$ messages = $ this ->queueManagement ->readMessages ('queue1 ' , 1 );
193
193
$ message = array_shift ($ messages );
194
- if ($ message [QueueManagement::MESSAGE_QUEUE_RELATION_ID ] == $ messageRelationId ) {
195
- $ retryMessage = $ message ;
196
- }
194
+ $ this ->assertEquals ($ messageRelationId , $ message [QueueManagement::MESSAGE_QUEUE_RELATION_ID ]);
197
195
}
198
- $ this ->assertNotNull ($ retryMessage , 'Made retry message not found in queue ' );
199
- $ this ->assertEquals (1 , $ retryMessage [QueueManagement::MESSAGE_NUMBER_OF_TRIALS ]);
200
196
}
201
- }
197
+ }
You can’t perform that action at this time.
0 commit comments