Sha256: 538c1409104be32cf586fc8291734b1221e62452e8f6d65330799a8aefec4154

Contents?: true

Size: 1.54 KB

Versions: 5

Compression:

Stored size: 1.54 KB

Contents

@in_memory
@bunny
Feature: 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::Broker.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

5 entries across 5 versions & 1 rubygems

Version Path
message-driver-0.2.2 features/message_consumers.feature
message-driver-0.2.1 features/message_consumers.feature
message-driver-0.2.0 features/message_consumers.feature
message-driver-0.2.0.rc2 features/message_consumers.feature
message-driver-0.2.0.rc1 features/message_consumers.feature