Sha256: 2a11f5cc9a21c8af062fedb03d1075755ecea8296f79e66390cd4f0af7c3a019
Contents?: true
Size: 1.55 KB
Versions: 13
Compression:
Stored size: 1.55 KB
Contents
@in_memory
@bunny
Feature: Basics of Message Consumers
Background:
Given I am connected to the broker
And I have a destination :dest_queue with no messages on it
And I have a destination :source_queue with no messages on it
And I have a message consumer
"""ruby
MessageDriver::Client.consumer(:my_consumer) do |message|
MessageDriver::Client.publish(:dest_queue, message.body)
end
"""
And I create a subscription
"""ruby
MessageDriver::Client.subscribe(:source_queue, :my_consumer)
"""
Scenario: Consuming Messages
When I send the following messages to :source_queue
| body |
| Test Message 1 |
| Test Message 2 |
And I let the subscription process
Then I expect to find no messages on :source_queue
And I expect to find the following 2 messages on :dest_queue
| body |
| Test Message 1 |
| Test Message 2 |
Scenario: Ending a subscription
When I send the following messages to :source_queue
| body |
| Test Message 1 |
| Test Message 2 |
And I allow for processing
And I cancel the subscription
And I send the following messages to :source_queue
| body |
| Test Message 3 |
| Test Message 4 |
Then I expect to find the following 2 messages on :dest_queue
| body |
| Test Message 1 |
| Test Message 2 |
And I expect to find the following 2 messages on :source_queue
| body |
| Test Message 3 |
| Test Message 4 |
Version data entries
13 entries across 13 versions & 1 rubygems