@@ -23,14 +23,18 @@ module Workling # subscribe to a queue def subscribe(key) - @amq.queue(key).subscribe do |value| + @amq.queue(key).subscribe do |data| + value = Marshal.load(data) yield value end end # request and retrieve work def retrieve(key); @amq.queue(key); end - def request(key, value); @amq.queue(key).publish(value); end + def request(key, value) + data = Marshal.dump(value) + @amq.queue(key).publish(data) + end end end -end \ No newline at end of file +end lib/workling/clients/amqp_client.rb 550799ddffacb7db86f0d7c712cde647ccb6e600 Ryan Tomayko rtomayko@gmail.com http://github.com/purzelrakete/workling/commit/a7b52c7c158ab0f9ccaf963d0aa56266a5e91c00 a7b52c7c158ab0f9ccaf963d0aa56266a5e91c00 2009-03-18T11:34:00-07:00 2009-03-18T07:49:45-07:00 Marshal AMQP message data The AMQP client does not seem to work with the latest tmm1-amqp gem. The message placed on the queue was the result of calling value#to_s. When the message was pulled off the queue it was the string representation of the value hash. This patch marshals the message Hash before placing publishing it and then unmarshals when it picks it up. Signed-off-by: Rany Keddo <rany@playtype.net> 4637e702101e34457dbfa9232bd94efb9aacc4ec Rany Keddo rany@playtype.net