File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change 17
17
18
18
module Lambdakiq
19
19
20
- def handle ( event )
21
- Job . handle ( event )
20
+ def handler ( event )
21
+ Job . handler ( event )
22
22
end
23
23
24
24
def jobs? ( event )
Original file line number Diff line number Diff line change @@ -5,7 +5,7 @@ class Job
5
5
6
6
class << self
7
7
8
- def handle ( event )
8
+ def handler ( event )
9
9
records = Event . records ( event )
10
10
jobs = records . map { |record | new ( record ) }
11
11
jobs . each ( &:perform )
Original file line number Diff line number Diff line change @@ -4,15 +4,15 @@ class JobTest < LambdakiqSpec
4
4
it 'must change message visibility to next value for failed jobs' do
5
5
stub_get_queue_attributes maxReceiveCount : 8
6
6
event = event_basic attributes : { ApproximateReceiveCount : '7' } , job_class : 'TestHelper::Jobs::ErrorJob'
7
- expect ( -> { Lambdakiq ::Job . handle ( event ) } ) . must_raise 'HELL'
7
+ expect ( -> { Lambdakiq ::Job . handler ( event ) } ) . must_raise 'HELL'
8
8
expect ( change_message_visibility ) . must_be :present?
9
9
expect ( change_message_visibility_params [ :visibility_timeout ] ) . must_equal 1416
10
10
end
11
11
12
12
it 'must delete message for failed jobs at the end of the queue/message max receive count' do
13
13
stub_get_queue_attributes maxReceiveCount : 8
14
14
event = event_basic attributes : { ApproximateReceiveCount : '8' } , job_class : 'TestHelper::Jobs::ErrorJob'
15
- Lambdakiq ::Job . handle ( event )
15
+ Lambdakiq ::Job . handler ( event )
16
16
expect ( delete_message ) . must_be :present?
17
17
end
18
18
end
You can’t perform that action at this time.
0 commit comments