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