@@ -105,8 +105,12 @@ public function getRelatedItemsOnUpdateQuery(
105105 return null ;
106106 }
107107
108- if (!$ element instanceof Concrete || !$ element ->getClass ()->getAllowInherit ()) {
109- return $ this ->getRelatedItemsQueryBuilder ($ element , $ operation , $ operationTime , $ includeElement );
108+ if (
109+ ($ operation === IndexQueueOperation::DELETE ->value ) ||
110+ !$ element instanceof Concrete ||
111+ !$ element ->getClass ()->getAllowInherit ()
112+ ) {
113+ return $ this ->getElementQueryBuilder ($ element , $ operation , $ operationTime , $ includeElement );
110114 }
111115
112116 if ($ operation !== IndexQueueOperation::UPDATE ->value ) {
@@ -153,7 +157,7 @@ public function getUpdateIndexDataEvent(
153157 throw new InvalidArgumentException ('Element must be instance of ' . AbstractObject::class);
154158 }
155159
156- private function getRelatedItemsQueryBuilder (
160+ private function getElementQueryBuilder (
157161 AbstractObject $ element ,
158162 string $ operation ,
159163 int $ operationTime ,
@@ -164,7 +168,7 @@ private function getRelatedItemsQueryBuilder(
164168 }
165169
166170 $ queryBuilder = $ this ->dbConnection ->createQueryBuilder ()
167- ->select ($ this ->getSelectParametersByOperation ($ element , $ operation , $ operationTime ))
171+ ->select ($ this ->getSelectParameters ($ element , $ operation , $ operationTime ))
168172 ->setMaxResults (1 );
169173
170174 if ($ operation === IndexQueueOperation::DELETE ->value ) {
@@ -177,7 +181,7 @@ private function getRelatedItemsQueryBuilder(
177181 ->setParameter ('id ' , $ element ->getId ());
178182 }
179183
180- private function getSelectParametersByOperation (
184+ private function getSelectParameters (
181185 AbstractObject $ element ,
182186 string $ operation ,
183187 int $ operationTime
0 commit comments