Contents

module EventAggregator
	
	# Public: MessageJob is a class used by the EventAggregator::Aggregator
	# for processing message distribution.
	#
	class MessageJob
		
		# 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
		def perform(data, callback)
			begin
				callback.call(data)
			rescue Exception => e
				STDERR.puts e.message
				STDERR.puts e.backtrace
			end
		end
	end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
event_aggregator-1.1.6	lib/event_aggregator/message_job.rb