# File gofer/messaging/consumer.rb, line 141 def next(timeout=nil) m = @incoming.get(true, timeout) if !m.nil? puts "message: \"#{m.body}\" received" envelope = JSON.parse(m.body) puts "#{self.id} read next:\n#{envelope}" return envelope end end