Contents

module EventAggregator
	
	# Public: MessageJob is a class used by the EventAggregator::Aggregator
	# for processing message distribution.
	#
	class MessageJob
		include SuckerPunch::Job
		
		# 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)
			callback.call(data)
		end
	end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
event_aggregator-1.1.0	lib/event_aggregator/message_job.rb
event_aggregator-1.0.2	lib/event_aggregator/message_job.rb
event_aggregator-1.0.1	lib/event_aggregator/message_job.rb