Contents

module QueueEngineExamples
  
  let(:queue) { engine[:test_queue] }

  it 'Engine' do
    engine.queues.must_be_empty
    
    queue = engine[:test_engine]
    queue.must_be_instance_of engine.class.const_get(:Queue)
    engine.queues.must_equal [:test_engine]
    
    engine[:test_engine].must_equal queue
    
    engine.clear
    engine.queues.must_be_empty
  end

  it 'Queue (push/pop)' do
    queue.must_be_empty
    
    queue.push 'msg_1'
    queue.push 'msg_2'
    
    queue.size.must_equal 2
    queue.to_a.must_equal %w(msg_1 msg_2)

    queue.pop.must_equal 'msg_1'

    queue.size.must_equal 1
    queue.to_a.must_equal %w(msg_2)
  end

  it 'Listener' do
    Timeout.timeout(5) do
      queue.push 'msg_1'
      queue.push 'msg_2'

      messages = []

      listener.listen(queue) do |msg|
        messages << msg
        listener.stop if queue.empty?
      end

      messages.must_equal %w(msg_1 msg_2)
    end
  end

  it 'Active connections' do
    engine.active_connections.must_equal [Asynchronic.connection_name]
  end

end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
asynchronic-3.0.3	spec/queue_engine/queue_engine_examples.rb
asynchronic-3.0.2	spec/queue_engine/queue_engine_examples.rb
asynchronic-3.0.1	spec/queue_engine/queue_engine_examples.rb
asynchronic-3.0.0	spec/queue_engine/queue_engine_examples.rb
asynchronic-2.0.1	spec/queue_engine/queue_engine_examples.rb
asynchronic-2.0.0	spec/queue_engine/queue_engine_examples.rb