lib/message_driver/message.rb in message-driver-0.6.1 vs lib/message_driver/message.rb in message-driver-0.7.0

- old
+ new

@@ -1,13 +1,14 @@ module MessageDriver module Message class Base include Logging - attr_reader :ctx, :body, :raw_body, :headers, :properties + attr_reader :ctx, :destination, :body, :raw_body, :headers, :properties - def initialize(ctx, body, headers, properties, raw_body = nil) + def initialize(ctx, destination, body, headers, properties, raw_body = nil) @ctx = ctx + @destination = destination @body = body @headers = headers @properties = properties @raw_body = raw_body.nil? ? body : raw_body end