Contents

When /^a message is published to queue '(\w+)'$/ do |q|
  publish_message("Hello World!", {:options => {:ack => "client"}}.merge(:to => q))
end

Then /^the message should be consumed$/ do
  sleep 1
  RosettaQueue::Consumer.receive(:foo).should =~ /Hello World!/
  # consume_once_with(SampleConsumer).should =~ /Hello World!/

  # RosettaQueue::EventedManager.create do |m|
  # 
  #   m.add(SampleConsumer.new)
  #   m.start
  # 
  # end
end

Given /^the message "(.+)" is published to queue "(.+)"$/ do |message, queue_name|
  publish_message(message, {:options => {:ack => "client"}}.merge(:to => queue_name))
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bmabey-rosetta_queue-0.1.3	features/messaging/step_definitions/point_to_point_steps.rb