# File lib/adaptation/mom.rb, line 25 def publish message, topic # Insert message into messages buffer, and awake # deliverer process (@sleeper) if paused puts "-----------------------------------" puts "Received message in topic: #{topic}" puts "#{message}" puts "-----------------------------------" @messages << [message, topic] @sleeper.run if @sleeper.stop? end