# File lib/activemessaging/adapters/test.rb, line 88 def all_messages @destinations.map {|q| q.messages }.flatten end
# File lib/activemessaging/adapters/test.rb, line 21 def disconnect @subscriptions = [] @destinations = [] @received_messages = [] @unreceived_messages = [] @connected = false end
# File lib/activemessaging/adapters/test.rb, line 80 def find_destination destination_name @destinations.find{|q| q.name == destination_name } end
test helper methods
# File lib/activemessaging/adapters/test.rb, line 63 def find_message destination_name, body all_messages.find do |m| m.destination == destination_name && if body.is_a?(Regexp) m.body =~ body else m.body == body.to_s end end end
# File lib/activemessaging/adapters/test.rb, line 84 def find_subscription destination_name @subscriptions.find{|s| s.name == destination_name} end
# File lib/activemessaging/adapters/test.rb, line 74 def open_destination destination_name unless find_destination destination_name @destinations << Destination.new(destination_name) end end
# File lib/activemessaging/adapters/test.rb, line 47 def receive(options={}) destination = @destinations.find do |q| find_subscription(q.name) && !q.empty? end destination.receive unless destination.nil? end
# File lib/activemessaging/adapters/test.rb, line 54 def received message, headers={} @received_messages << message end
# File lib/activemessaging/adapters/test.rb, line 41 def send destination_name, message_body, message_headers={} open_destination destination_name destination = find_destination destination_name destination.send Message.new(message_body, nil, message_headers, destination_name) end
# File lib/activemessaging/adapters/test.rb, line 29 def subscribe destination_name, subscribe_headers={} open_destination destination_name unless @subscriptions.find {|s| s.name == destination_name} @subscriptions << Subscription.new(destination_name, subscribe_headers) end @subscriptions.last end
Generated with the Darkfish Rdoc Generator 2.