class Lapine::Consumer::Middleware::ErrorHandler

Attributes

app[R]

Public Class Methods

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

Public Instance Methods

call(message) click to toggle source
# File lib/lapine/consumer/middleware/error_handler.rb, line 11
def call(message)
  app.call(message)
rescue StandardError => e
  Lapine::Consumer::Dispatcher.error_handler.call(e, message.payload, message.metadata)
end