class Lapine::Consumer::Middleware::JsonDecoder

Attributes

app[R]

Public Class Methods

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

Public Instance Methods

call(message) click to toggle source
# File lib/lapine/consumer/middleware/json_decoder.rb, line 13
def call(message)
  message['decoded_payload'] = Oj.load(message.payload)
  app.call(message)
end