diff --git a/lib/iron_mq/messages.rb b/lib/iron_mq/messages.rb index c031e6b..63ef404 100644 --- a/lib/iron_mq/messages.rb +++ b/lib/iron_mq/messages.rb @@ -19,7 +19,7 @@ def get(options={}) res, status = @client.get(path(options), options) ret = [] res["messages"].each do |m| - ret << Message.new(self, res) + ret << Message.new(self, m) end if options[:n] return ret