Contents

module Messaging
  module Routing
    # Internal: Used for enqueing background jobs instead of calling the handler directly
    class BackgroundJobSubscriber < Subscriber
      def initialize(pattern, topic, handler)
        super
        @handler = EnqueueMessageHandler.new(handler)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
messaging-3.4.1	lib/messaging/routing/background_job_subscriber.rb