Module: Wakame::QueueDeclare

Included in:
Agent, Master
Defined in:
lib/wakame/queue_declare.rb

Class Method Summary collapse

Class Method Details

.included(klass) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/wakame/queue_declare.rb', line 5

def self.included(klass)
  klass.class_eval {
    define_exchange 'registry', :fanout
    define_exchange 'ping', :fanout
    define_exchange 'agent_command', :topic
    define_exchange 'agent_event', :fanout
  }
end