Class: Shoryuken::Middleware::Server::AutoExtendVisibility

Inherits:
Object
  • Object
show all
Defined in:
lib/shoryuken/middleware/server/auto_extend_visibility.rb

Defined Under Namespace

Classes: MessageVisibilityExtender

Constant Summary collapse

EXTEND_UPFRONT_SECONDS = 
5

Instance Method Summary collapse

Instance Method Details

#call(worker, queue, sqs_msg, body) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/shoryuken/middleware/server/auto_extend_visibility.rb', line 9

def call(worker, queue, sqs_msg, body)
  timer = auto_visibility_timer(worker, queue, sqs_msg, body)
  begin
    yield
  ensure
    if timer
      timer.cancel
      @visibility_extender.terminate
    end
  end
end