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