Contents

require File.expand_path("../../consumer", __FILE__)

module Vx
  module Consumer

    module Testing

      extend self

      @@messages = Hash.new { |h,k| h[k] = [] }
      @@messages_and_options = Hash.new { |h,k| h[k] = [] }

      def messages
        @@messages
      end

      def messages_and_options
        @@messages_and_options
      end

      def clear
        messages.clear
        messages_and_options.clear
      end
    end

    module Consumer::Publish

      def publish(message, options = nil)
        options ||= {}
        Testing.messages[params.exchange_name] << message
        Testing.messages_and_options[params.exchange_name] << [message, options]
        self
      end

      def messages
        Testing.messages[params.exchange_name]
      end

      def messages_and_options
        Testing.messages_and_options[params.exchange_name]
      end

    end

  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
vx-consumer-0.2.0	lib/vx/consumer/testing.rb
vx-consumer-0.2.0.pre0	lib/vx/consumer/testing.rb
vx-consumer-0.1.8	lib/vx/consumer/testing.rb
vx-consumer-0.1.7	lib/vx/consumer/testing.rb
vx-consumer-0.1.6	lib/vx/consumer/testing.rb
vx-consumer-0.1.5	lib/vx/consumer/testing.rb
vx-consumer-0.1.4	lib/vx/consumer/testing.rb
vx-consumer-0.1.3	lib/vx/consumer/testing.rb
vx-consumer-0.1.2	lib/vx/consumer/testing.rb
vx-consumer-0.1.1	lib/vx/consumer/testing.rb
vx-consumer-0.1.0	lib/vx/consumer/testing.rb
vx-consumer-0.0.2	lib/vx/consumer/testing.rb
vx-consumer-0.0.1	lib/vx/consumer/testing.rb