Module: Sidekiq::Sqs

Defined in:
lib/top_level.rb,
lib/sidekiq-sqs.rb,
lib/sidekiq-sqs/client.rb,
lib/sidekiq-sqs/worker.rb,
lib/sidekiq-sqs/fetcher.rb,
lib/sidekiq-sqs/manager.rb,
lib/sidekiq-sqs/version.rb,
lib/sidekiq-sqs/processor.rb,
lib/sidekiq-sqs/aws-sdk/batch_send_failure_patch.rb

Defined Under Namespace

Modules: AwsSdk, Client, Fetcher, Manager, Processor, TopLevel, Worker

Constant Summary collapse

VERSION = 
"0.0.17"

Class Method Summary collapse

Class Method Details

.enable! ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/sidekiq-sqs.rb', line 18

def enable!
  require 'sidekiq/manager'
  require 'sidekiq/fetch'
  require 'sidekiq/client'
  require 'sidekiq/processor'
  require 'sidekiq-sqs/util'

  Sidekiq::Manager.send :include, Sidekiq::Sqs::Manager
  Sidekiq::Fetcher.send :include, Sidekiq::Sqs::Fetcher
  Sidekiq::Client.send :include, Sidekiq::Sqs::Client
  Sidekiq::Processor.send :include, Sidekiq::Sqs::Processor
  Sidekiq::Worker::ClassMethods.send :include, Sidekiq::Sqs::Worker
  AWS::SQS::Queue.send :include, Sidekiq::Sqs::AwsSdk::BatchSendFailurePatch

  # Can't figure how to include/extend and not get a private method...
  def Sidekiq.sqs
    AWS::SQS.new
  end

  Sidekiq.configure_server do |config|
    config.server_middleware do |chain|
      chain.remove Sidekiq::Middleware::Server::RetryJobs
      chain.remove Sidekiq::Middleware::Server::Timeout
    end
  end
end