Module: EventHub::Helper

Included in:
ActorHeartbeat, ActorListener, ActorWatchdog, Message, Processor2
Defined in:
lib/eventhub/helper.rb

Overview

Helper module

Instance Method Summary collapse

Instance Method Details

#bunny_connection_properties ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/eventhub/helper.rb', line 22

def bunny_connection_properties
  server = EventHub::Configuration.server

  if Configuration.server[:tls]
    {
      user: server[:user],
      password: server[:password],
      host: server[:host],
      vhost: server[:vhost],
      port: server[:port],
      tls: server[:tls],
      logger: Logger.new('/dev/null'), # logs from Bunny not required
      network_recovery_interval: 15
    }
  else
    {
      user: server[:user],
      password: server[:password],
      host: server[:host],
      vhost: server[:vhost],
      port: server[:port],
      logger: Logger.new('/dev/null'), # logs from Bunny not required
      network_recovery_interval: 15
    }
  end
end

#get_name_from_class(instance) ⇒ Object

Examples: EventHub::Namespace::Demo => namespace.demo EventHub::NameSpace::Demo => name_space.demo EventHub::NameSpace::DemoProcessor => name_space.demo_processor NameSpace::Demo => name_space.demo



15
16
17
18
19
20
 
# File 'lib/eventhub/helper.rb', line 15

def get_name_from_class(instance)
  instance.class.to_s.split('::').map do |element|
    next if element == 'EventHub'
    element.split(/(?=[A-Z])/).join('_').downcase
  end.compact.join('.')
end

#now_stamp(now = nil) ⇒ Object

Formats stamp into UTC format



50
51
52
53
 
# File 'lib/eventhub/helper.rb', line 50

def now_stamp(now=nil)
  now ||= Time.now
  now.utc.strftime("%Y-%m-%dT%H:%M:%S.%6NZ")
end