Contents

module Cloudist
  module Utils
    extend self

    def reply_prefix(name)
      "temp.reply.#{name}"
    end

    def generate_queue(exchange_name, second_name=nil)
      second_name ||= $$
      "#{generate_name_for_instance(exchange_name)}.#{second_name}"
    end

    def generate_name_for_instance(name)
      "#{name}.#{Socket.gethostname}"
    end
    
    # DEPRECATED
    def generate_reply_to(name)
      "#{reply_prefix(name)}.#{generate_sym}"
    end

    def generate_sym
      values = [
        rand(0x0010000),
        rand(0x0010000),
        rand(0x0010000),
        rand(0x0010000),
        rand(0x0010000),
        rand(0x1000000),
        rand(0x1000000),
      ]
      "%04x%04x%04x%04x%04x%06x%06x" % values
    end
    
    def decode_json(string)
      if defined? ActiveSupport::JSON
        ActiveSupport::JSON.decode string
      else
        JSON.load string
      end
    end
    
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
cloudist-0.1.2	lib/cloudist/utils.rb
cloudist-0.1.1	lib/cloudist/utils.rb
cloudist-0.1.0	lib/cloudist/utils.rb
cloudist-0.0.3	lib/cloudist/utils.rb