fix breakage

sidekiq · Apr 8, 2022 · 1e01328 · 1e01328
1 parent 51697b8
commit 1e01328
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/lib/sidekiq/xaclient.rb b/lib/sidekiq/xaclient.rb
@@ -19,9 +19,9 @@ module XAClient
     #   * nil or false means enqueue the job immediately, Sidekiq's default behavior
     def push(item)
       # Sidekiq::Job does not merge sidekiq_options so we need to fallback
-      policy = item.delete("xa") {
+      policy = item.fetch("xa") { |key|
         kl = item["class"]
-        kl.is_a?(Sidekiq::Job) ? kl.get_sidekiq_options["xa"] : nil
+        kl.respond_to?(:get_sidekiq_options) ? kl.get_sidekiq_options[key] : nil
       }
       if policy == "commit" || policy == true
         after_commit { super }

diff --git a/test/test_xa.rb b/test/test_xa.rb
@@ -4,7 +4,7 @@
 require "sidekiq/api"
 require "sidekiq/rails"
 require "sidekiq/xaclient"
-Sidekiq.transactional!
+Sidekiq.transactional_push!
 
 require_relative "./dummy/config/environment"