Permalink
Browse files

explicitly specify args

  • Loading branch information...
1 parent 29855b6 commit 6af724a51e3cd95baf7a66f77a791c96ec44343d @seanohalpin committed Feb 6, 2012
Showing with 1 addition and 2 deletions.
  1. +1 −2 lib/smqueue/adapters/thread_queue.rb
@@ -41,7 +41,7 @@ def initialize(*args, &block)
def put(body, headers = { }, &block)
body, headers = normalize_message(body, headers)
- msg = SMQueue::Message.new(body, headers)
+ msg = SMQueue::Message.new(:body => body, :headers => headers)
#p [:tput, args]
thread_queue.enq(msg)
end
@@ -61,4 +61,3 @@ def get(*args, &block)
end
end
end
-

0 comments on commit 6af724a

Please sign in to comment.