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