class TrRMIte::Producers::Console
Public Class Methods
new(topic, queue_uri)
click to toggle source
Calls superclass method
TrRMIte::EventProducer::new
# File lib/TrRMIte/producers/console.rb, line 5 def initialize(topic, queue_uri) super(queue_uri) @topic = topic end
Private Instance Methods
munge(message)
click to toggle source
# File lib/TrRMIte/producers/console.rb, line 26 def munge(message) message end
next_event()
click to toggle source
# File lib/TrRMIte/producers/console.rb, line 12 def next_event if (message = $stdin.gets) Event.new( topic: @topic, type: 'Message', payload: { message: munge(message.chomp) } ) else nil end end