Contents

# frozen_string_literal: true

module SidekiqPublisher
  module Worker
    def self.included(base)
      base.include(SidekiqPublisher::Compatibility.sidekiq_job_class)
      base.singleton_class.public_send(:alias_method, :sidekiq_client_push, :client_push)
      base.extend(ClassMethods)
    end

    module ClassMethods
      def client_push(item)
        if SidekiqPublisher::DatabaseConnection.transaction_open?
          SidekiqPublisher::Job.create_job!(item)
        else
          super
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq_publisher-5.0.0	lib/sidekiq_publisher/worker.rb
sidekiq_publisher-4.0.0	lib/sidekiq_publisher/worker.rb