Contents

module FakeServiceBus
  class QueueFactory

    attr_reader :message_factory, :queue

    def initialize(options = {})
      @message_factory = options.fetch(:message_factory)
      @queue = options.fetch(:queue)
    end

    def new(options)
      queue.new(options.merge(:message_factory => message_factory))
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fake_servicebus-0.0.2	lib/fake_servicebus/queue_factory.rb