Skip to content

Commit 97698dd

Browse files
committed
Merge pull request #36 from thomasblass/RemoveHandledObjects
[Bugfix] Remove checking of HandledObjects
2 parents 41a695c + b3d6e4c commit 97698dd

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

Classes/Flowpack/ElasticSearch/Indexer/Object/ObjectIndexer.php

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -63,13 +63,6 @@ class ObjectIndexer {
6363
*/
6464
protected $client;
6565

66-
/**
67-
* Stores the objects which are already indexed in order to avoid duplicate indexing due to multiple notifications, for example
68-
*
69-
* @var array
70-
*/
71-
protected $handledObjects = array();
72-
7366
/**
7467
* (Re-) indexes an object to the ElasticSearch index, no matter if the change is actually required.
7568
*
@@ -80,12 +73,6 @@ class ObjectIndexer {
8073
* @return void
8174
*/
8275
public function indexObject($object, $signalInformation = NULL, Client $client = NULL) {
83-
$objectHash = spl_object_hash($object);
84-
if (isset($this->handledObjects[$objectHash])) {
85-
return;
86-
}
87-
$this->handledObjects[$objectHash] = true;
88-
8976
$type = $this->getIndexTypeForObject($object, $client);
9077
if ($type === NULL) {
9178
return NULL;
@@ -124,12 +111,6 @@ protected function getIndexablePropertiesAndValuesFromObject($object) {
124111
* @param \Flowpack\ElasticSearch\Domain\Model\Client $client
125112
*/
126113
public function removeObject($object, $signalInformation = NULL, Client $client = NULL) {
127-
$objectHash = spl_object_hash($object);
128-
if (isset($this->handledObjects[$objectHash])) {
129-
return;
130-
}
131-
$this->handledObjects[$objectHash] = true;
132-
133114
$type = $this->getIndexTypeForObject($object, $client);
134115
if ($type === NULL) {
135116
return;

0 commit comments

Comments
 (0)