lamoda /
queue-bundle
| @@ 67-82 (lines=16) @@ | ||
| 64 | * |
|
| 65 | * @return array |
|
| 66 | */ |
|
| 67 | public function dataRestoreQueues(): array |
|
| 68 | { |
|
| 69 | $queueEntity = $this->getQueueEntity(); |
|
| 70 | $queueEntity2 = $this->getQueueEntity(); |
|
| 71 | Reflection::setProtectedProperty($queueEntity, 'id', 1); |
|
| 72 | Reflection::setProtectedProperty($queueEntity2, 'id', 2); |
|
| 73 | ||
| 74 | return [ |
|
| 75 | [ |
|
| 76 | [ |
|
| 77 | $queueEntity, |
|
| 78 | $queueEntity2, |
|
| 79 | ], |
|
| 80 | ], |
|
| 81 | ]; |
|
| 82 | } |
|
| 83 | ||
| 84 | /** |
|
| 85 | * @param array $queueMessages |
|
| @@ 245-260 (lines=16) @@ | ||
| 242 | * |
|
| 243 | * @return array |
|
| 244 | */ |
|
| 245 | public function dataRestoreQueuesFailedOnPublisherReleaseFailed(): array |
|
| 246 | { |
|
| 247 | $queueEntity = $this->getQueueEntity(); |
|
| 248 | $queueEntity2 = $this->getQueueEntity(); |
|
| 249 | Reflection::setProtectedProperty($queueEntity, 'id', 1); |
|
| 250 | Reflection::setProtectedProperty($queueEntity2, 'id', 2); |
|
| 251 | ||
| 252 | return [ |
|
| 253 | [ |
|
| 254 | [ |
|
| 255 | $queueEntity, |
|
| 256 | $queueEntity2, |
|
| 257 | ], |
|
| 258 | ], |
|
| 259 | ]; |
|
| 260 | } |
|
| 261 | ||
| 262 | /** |
|
| 263 | * @param string $jobName |
|
