Module: Cloudist::Utils

Extended by:
Utils
Included in:
Payload, Utils
Defined in:
lib/cloudist/utils.rb

Instance Method Summary collapse

Instance Method Details

#decode_json(string) ⇒ Object 



52
53
54
55
56
57
58
 
# File 'lib/cloudist/utils.rb', line 52

def decode_json(string)
  if defined? ActiveSupport::JSON
    ActiveSupport::JSON.decode string
  else
    JSON.load string
  end
end

#decode_message(string) ⇒ Object 



48
49
50
 
# File 'lib/cloudist/utils.rb', line 48

def decode_message(string)
  Marshal.load(string)
end

#encode_message(object) ⇒ Object 



44
45
46
 
# File 'lib/cloudist/utils.rb', line 44

def encode_message(object)
  Marshal.dump(object).to_s
end

#generate_name_for_instance(name) ⇒ Object 



22
23
24
 
# File 'lib/cloudist/utils.rb', line 22

def generate_name_for_instance(name)
  "#{name}.#{Socket.gethostname}"
end

#generate_queue(exchange_name, second_name = nil) ⇒ Object 



17
18
19
20
 
# File 'lib/cloudist/utils.rb', line 17

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

#generate_reply_to(name) ⇒ Object

DEPRECATED



27
28
29
 
# File 'lib/cloudist/utils.rb', line 27

def generate_reply_to(name)
  "#{reply_prefix(name)}.#{generate_sym}"
end

#generate_sym ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/cloudist/utils.rb', line 31

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

#log_prefix(name) ⇒ Object 



9
10
11
 
# File 'lib/cloudist/utils.rb', line 9

def log_prefix(name)
  "temp.log.#{name}"
end

#reply_prefix(name) ⇒ Object 



5
6
7
 
# File 'lib/cloudist/utils.rb', line 5

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

#stats_prefix(name) ⇒ Object 



13
14
15
 
# File 'lib/cloudist/utils.rb', line 13

def stats_prefix(name)
  "temp.stats.#{name}"
end