...

aemadrid · Mar 24, 2015 · bae1de3 · bae1de3
1 parent 7e475c2
commit bae1de3
Show file tree

Hide file tree

Showing 6 changed files with 13 additions and 0 deletions.
diff --git a/.rspec b/.rspec
diff --git a/spec/integration/multiple_consumer_spec.rb b/spec/integration/multiple_consumer_spec.rb
@@ -0,0 +1,13 @@
+describe 'simple consumers', integration: true do
+  let(:consumer) { SimpleConsumer }
+
+  it 'receives multiple messages' do
+    (1..4).each { |nr| Tiki::Torch.publish consumer.topic, "a#{nr}" }
+    sleep 1
+
+    # Get all messages
+    expect($messages.payloads).to eq %w{ a1 a2 a3 a4 }
+    # All different threads
+    expect($messages.thread_ids.uniq.size).to eq 4
+  end
+end
diff --git a/spec/integration/simple_consumer_spec.rb b/spec/integration/simple_consumer_spec.rb
diff --git a/spec/spec_helper.rb b/spec/spec_helper.rb
diff --git a/spec/support/consumers.rb b/spec/support/consumers.rb
diff --git a/spec/support/helpers.rb b/spec/support/helpers.rb