class EventAggregator::MessageJob
Public: MessageJob
is a class used by the EventAggregator::Aggregator
for processing message distribution.
Public Instance Methods
perform(data, callback)
click to toggle source
Public: Duplicate some text an arbitrary number of times.
data - The data that will be sent to the callback, originating from a message. callback - The callback that will be processed with the data as a parameter
# File lib/event_aggregator/message_job.rb, line 14 def perform(data, callback) begin callback.call(data) rescue Exception => e STDERR.puts e.message STDERR.puts e.backtrace end end