Contents

require 'timecop'
require 'queue-bus'
require 'adapter/support'

reset_test_adapter

module QueueBus
  class Runner
    def self.value
      @value ||= 0
    end

    def self.attributes
      @attributes
    end

    def self.run(attrs)
      @value ||= 0
      @value += 1
      @attributes = attrs
    end

    def self.reset
      @value = nil
      @attributes = nil
    end
  end

  class Runner1 < Runner
  end

  class Runner2 < Runner
  end
end

def test_sub(event_name, queue="default")
  matcher = {"bus_event_type" => event_name}
  QueueBus::Subscription.new(queue, event_name, "::QueueBus::Rider", matcher, nil)
end

def test_list(*args)
  out = QueueBus::SubscriptionList.new
  args.each do |sub|
    out.add(sub)
  end
  out
end

RSpec.configure do |config|
  config.mock_with :rspec do |c|
    c.syntax = :expect
  end
  config.expect_with :rspec do |c|
    c.syntax = :expect
  end

  config.before(:each) do
    reset_test_adapter
  end
  config.after(:each) do
    begin
      QueueBus.redis { |redis| redis.flushall }
    rescue
    end
    QueueBus.send(:reset)
    QueueBus::Runner1.reset
    QueueBus::Runner2.reset
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
queue-bus-0.6.0	spec/spec_helper.rb