Contents

module BunnyMock
	module Exchanges
		class Fanout < BunnyMock::Exchange

			#
			# API
			#

			##
			# Deliver a message to all routes
			#
			# @param [Object] payload Message content
			# @param [Hash] opts Message properties
			# @param [String] key Routing key
			#
			# @api public
			#
			def deliver(payload, opts, key)

				@routes.each do |route, destination|

					# send to all routes
					destination.publish payload, opts
				end
			end
		end
	end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
bunny-mock-1.1.0	lib/bunny_mock/exchanges/fanout.rb
bunny-mock-1.0.0	lib/bunny_mock/exchanges/fanout.rb