Module: Mumukit::Nuntius::Publisher

Defined in:
lib/mumukit/nuntius/publisher.rb

Class Method Summary collapse

Class Method Details

.method_missing(name, *args, &block) ⇒ Object



11
12
13
14
15
16
17
18
# File 'lib/mumukit/nuntius/publisher.rb', line 11

def method_missing(name, *args, &block)
  if name.to_s.starts_with? 'publish_'
    queue_name = name.to_s.split('publish_').last
    publish queue_name, *args
  else
    super
  end
end

.publish(queue_name, data) ⇒ Object



5
6
7
8
9
# File 'lib/mumukit/nuntius/publisher.rb', line 5

def publish(queue_name, data)
  connection, channel, queue = Mumukit::Nuntius::Connection.start(queue_name)
  channel.persistent_publish(data.to_json, queue_name)
  connection.close
end