Merge pull request #140 from enesaktay/remove-date-check-from-mq-import

remove date check on import
FriendsOfSylius · Jul 25, 2018 · 177b996 · 177b996
2 parents dc65244 + 2d51372
commit 177b996
Showing 1 changed file with 0 additions and 12 deletions.
diff --git a/src/Exporter/MqItemReader.php b/src/Exporter/MqItemReader.php
@@ -65,22 +65,10 @@ public function readAndImport(): void
         /** @var RedisConsumer $consumer */
         $consumer = $this->redisContext->createConsumer($this->queue);
 
-        $dataTimestampArray = [];
-
         /** @var RedisMessage $message */
         while ($message = $consumer->receive()) {
             $dataArrayToImport = (array) json_decode($message->getBody());
-            $dataTimestamp = strtotime($message->getHeader('recordedOn'));
-
-            if (array_key_exists($dataArrayToImport['Id'], $dataTimestampArray)) {
-                if ($dataTimestampArray[$dataArrayToImport['Id']] >= $dataTimestamp) {
-                    ++$this->messagesSkippedCount;
-
-                    continue;
-                }
-            }
 
-            $dataTimestampArray[$dataArrayToImport['Id']] = $dataTimestamp;
             $this->service->importSingleDataArrayWithoutResult($dataArrayToImport);
             ++$this->messagesImportedCount;
         }