Contents

# frozen_string_literal: true
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_value { |destination| destination.publish(payload, opts) }
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
bunny-mock-1.2.2	lib/bunny_mock/exchanges/fanout.rb
bunny-mock-1.2.1	lib/bunny_mock/exchanges/fanout.rb
bunny-mock-1.2.0	lib/bunny_mock/exchanges/fanout.rb