@@ -39,7 +39,7 @@ public function __construct(IndexerRegistry $indexerRegistry, ConfigHelper $conf
39
39
public function beforeSave (ProductResource $ productResource , ProductModel $ product )
40
40
{
41
41
$ productResource ->addCommitCallback (function () use ($ product ) {
42
- if (!$ this ->indexer ->isScheduled () || $ this -> configHelper -> isQueueActive () ) {
42
+ if (!$ this ->indexer ->isScheduled ()) {
43
43
$ this ->indexer ->reindexRow ($ product ->getId ());
44
44
}
45
45
});
@@ -60,7 +60,7 @@ public function beforeSave(ProductResource $productResource, ProductModel $produ
60
60
public function beforeDelete (ProductResource $ productResource , ProductModel $ product )
61
61
{
62
62
$ productResource ->addCommitCallback (function () use ($ product ) {
63
- if (!$ this ->indexer ->isScheduled () || $ this -> configHelper -> isQueueActive () ) {
63
+ if (!$ this ->indexer ->isScheduled ()) {
64
64
$ this ->indexer ->reindexRow ($ product ->getId ());
65
65
}
66
66
});
@@ -77,7 +77,7 @@ public function beforeDelete(ProductResource $productResource, ProductModel $pro
77
77
*/
78
78
public function afterUpdateAttributes (Action $ subject , Action $ result = null , $ productIds )
79
79
{
80
- if (!$ this ->indexer ->isScheduled () || $ this -> configHelper -> isQueueActive () ) {
80
+ if (!$ this ->indexer ->isScheduled ()) {
81
81
$ this ->indexer ->reindexList (array_unique ($ productIds ));
82
82
}
83
83
@@ -93,7 +93,7 @@ public function afterUpdateAttributes(Action $subject, Action $result = null, $p
93
93
*/
94
94
public function afterUpdateWebsites (Action $ subject , Action $ result = null , array $ productIds )
95
95
{
96
- if (!$ this ->indexer ->isScheduled () || $ this -> configHelper -> isQueueActive () ) {
96
+ if (!$ this ->indexer ->isScheduled ()) {
97
97
$ this ->indexer ->reindexList (array_unique ($ productIds ));
98
98
}
99
99
0 commit comments