Call out to ActiveSupport for notications [skip ci]

Andrew
1 parent 38880598
Showing 1 changed file with 6 additions and 1 deletions Show diff stats
lib/searchkick/bulk_indexer.rb
@@ -63,7 +63,12 @@ module Searchkick
           records = records.select(&:should_index?)
           if records.any?
             with_retries do
-              method_name ? bulk_update(records, method_name) : bulk_index(records)
+              # call out to index for ActiveSupport notifications
+              if method_name
+                index.bulk_update(records, method_name)
+              else
+                index.bulk_index(records)
+              end
             end
           end
         end
...	...	@@ -63,7 +63,12 @@ module Searchkick
63	63	records = records.select(&:should_index?)
64	64	if records.any?
65	65	with_retries do
66		- method_name ? bulk_update(records, method_name) : bulk_index(records)
	66	+ # call out to index for ActiveSupport notifications
	67	+ if method_name
	68	+ index.bulk_update(records, method_name)
	69	+ else
	70	+ index.bulk_index(records)
	71	+ end
67	72	end
68	73	end
69	74	end
...	...