lib/cloudist/utils.rb in cloudist-0.1.2 vs lib/cloudist/utils.rb in cloudist-0.2.0

@@ -4,10 +4,18 @@
 
     def reply_prefix(name)
       "temp.reply.#{name}"
     end
 
+    def log_prefix(name)
+      "temp.log.#{name}"
+    end
+
+    def stats_prefix(name)
+      "temp.stats.#{name}"
+    end
+
     def generate_queue(exchange_name, second_name=nil)
       second_name ||= $$
       "#{generate_name_for_instance(exchange_name)}.#{second_name}"
     end
 
@@ -29,9 +37,17 @@
         rand(0x0010000),
         rand(0x1000000),
         rand(0x1000000),
       ]
       "%04x%04x%04x%04x%04x%06x%06x" % values
+    end
+    
+    def encode_message(object)
+      Marshal.dump(object).to_s
+    end
+    
+    def decode_message(string)
+      Marshal.load(string)
     end
     
     def decode_json(string)
       if defined? ActiveSupport::JSON
         ActiveSupport::JSON.decode string