Contents

require 'unit_spec_helper'

describe Rpush::Daemon::DispatcherLoop do
  def run_dispatcher_loop
    dispatcher_loop.start
    dispatcher_loop.stop
    dispatcher_loop.wakeup
    dispatcher_loop.wait
  end

  let(:notification) { double }
  let(:batch) { double(notification_processed: nil) }
  let(:queue) { Queue.new }
  let(:dispatcher) { double(dispatch: nil, cleanup: nil) }
  let(:dispatcher_loop) { Rpush::Daemon::DispatcherLoop.new(queue, dispatcher) }
  let(:store) { double(Rpush::Daemon::Store::ActiveRecord, release_connection: nil) }

  before do
    Rpush::Daemon.stub(store: store)
    queue.push([notification, batch])
  end

  it 'logs errors' do
    logger = double
    Rpush.stub(logger: logger)
    error = StandardError.new
    dispatcher.stub(:dispatch).and_raise(error)
    Rpush.logger.should_receive(:error).with(error)
    run_dispatcher_loop
  end

  it 'reflects an exception' do
    Rpush.stub(logger: double(error: nil))
    error = StandardError.new
    dispatcher.stub(:dispatch).and_raise(error)
    dispatcher_loop.should_receive(:reflect).with(:error, error)
    run_dispatcher_loop
  end

  it 'instructs the queue to wakeup the thread when told to stop' do
    queue.should_receive(:push).with(Rpush::Daemon::DispatcherLoop::WAKEUP).and_call_original
    run_dispatcher_loop
  end

  describe 'stop' do
    before do
      queue.clear
      queue.push(Rpush::Daemon::DispatcherLoop::WAKEUP)
    end

    it 'does not attempt to dispatch when a WAKEUP is dequeued' do
      dispatcher.should_not_receive(:dispatch)
      run_dispatcher_loop
    end

    it 'instructs the dispatcher to cleanup' do
      dispatcher.should_receive(:cleanup)
      run_dispatcher_loop
    end

    it 'releases the store connection' do
      Rpush::Daemon.store.should_receive(:release_connection)
      run_dispatcher_loop
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rpush-2.0.0.beta1	spec/unit/daemon/dispatcher_loop_spec.rb