Contents

Given(/^I have a dynamic destination "(#{STRING_OR_SYM})" with the following messages on it:$/) do |destination, table|
  dest = MessageDriver::Broker.dynamic_destination(destination, exclusive: true)
  test_runner.publish_table_to_destination(dest, table)
end

Then(/^I expect to find (#{NUMBER}) messages? on the dynamic destination "(#{STRING_OR_SYM})" with:$/) do |count, destination, table|
  expect(test_runner).to have_no_errors
  dest = MessageDriver::Broker.dynamic_destination(destination, passive: true)
  messages = test_runner.fetch_messages(dest)
  expect(messages).to have(count).items
  expect(messages).to match_message_table(table)
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
message-driver-0.1.0	features/step_definitions/dynamic_destinations_steps.rb