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