spec/models/supervisor_spec.rb in toiler-0.5.1.pre9 vs spec/models/supervisor_spec.rb in toiler-0.5.1
- old
+ new
@@ -11,10 +11,10 @@
def perform(sqs_message, body); end
end
Toiler.options.merge!(active_queues: ['default'])
expect(::Aws::SQS::Client).to receive(:new).and_return(sqs_client)
- expect(Toiler::Actor::Fetcher).to receive(:spawn!).with(name: :fetcher_default, supervise: true, args: ['default', sqs_client, 1])
+ expect(Toiler::Actor::Fetcher).to receive(:spawn!).with(name: :fetcher_default, supervise: true, args: ['default', sqs_client])
expect(Concurrent::Actor::Utils::Pool).to receive(:spawn!).with(:processor_pool_default, 1)
supervisor = described_class.new
end
it 'warns when a queue is missing' do