class MessageDriver::Middleware::Base
Attributes
destination[R]
Public Class Methods
new(*args)
click to toggle source
# File lib/message_driver/middleware/base.rb, line 6 def initialize(*args) @destination = args.shift end
Public Instance Methods
on_consume(body, headers, properties)
click to toggle source
# File lib/message_driver/middleware/base.rb, line 14 def on_consume(body, headers, properties) [body, headers, properties] end
on_publish(body, headers, properties)
click to toggle source
# File lib/message_driver/middleware/base.rb, line 10 def on_publish(body, headers, properties) [body, headers, properties] end