Sha256: f5d7a17d279aeb876e713235d8ac85e000400a50974e74d1588a21482f06af43

Contents?: true

Size: 530 Bytes

Versions: 4

Compression:

Stored size: 530 Bytes

Contents

Then /^a (receiving|sending) filter is defined to prepend 'Foo' to all messages$/ do |filter_type|
  RosettaQueue::Filters.reset
  RosettaQueue::Filters.define do |f|
    f.send(filter_type) { |message| "Foo #{message}" }
  end
end

When /^the message on '(.+)' is consumed$/ do |queue_name|
  # TODO
  # @consumed_message = queue(:foo_queue).pop
  @consumed_message = consume_once(queue_name.to_sym)
end

Then /^the consumed message should equal "(.+)"$/ do |consumed_message|
  @consumed_message.should == consumed_message
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version Path
bmabey-rosetta_queue-0.3.3 features/step_definitions/filtering_steps.rb
rosetta_queue-0.5.2 features/step_definitions/filtering_steps.rb
rosetta_queue-0.5.0 features/step_definitions/filtering_steps.rb
rosetta_queue-0.4.0 features/step_definitions/filtering_steps.rb