class Lapine::Consumer::Middleware::MessageAckHandler

Attributes

app[R]

Public Class Methods

new(app) click to toggle source
# File lib/lapine/consumer/middleware/message_ack_handler.rb, line 7
def initialize(app)
  @app = app
end

Public Instance Methods

call(message) click to toggle source
# File lib/lapine/consumer/middleware/message_ack_handler.rb, line 11
def call(message)
  app.call(message)
ensure
  message.metadata.ack
end