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