Class: RosettaQueue::Gateway::FakeAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/rosetta_queue/adapters/fake.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ FakeAdapter

Returns a new instance of FakeAdapter.



6
7
8
 
# File 'lib/rosetta_queue/adapters/fake.rb', line 6

def initialize
  @messages = []
end

Instance Method Details

#messages_sent_to(queue) ⇒ Object 



14
15
16
 
# File 'lib/rosetta_queue/adapters/fake.rb', line 14

def messages_sent_to(queue)
  (queue ? @messages.select{|message| message['queue'] == queue} : @messages).map{|m| m['message']}
end

#queues ⇒ Object 



18
19
20
 
# File 'lib/rosetta_queue/adapters/fake.rb', line 18

def queues
  @messages.map {|message| message['queue']}
end

#send_message(queue, message, headers) ⇒ Object 



10
11
12
 
# File 'lib/rosetta_queue/adapters/fake.rb', line 10

def send_message(queue, message, headers)
  @messages << {'queue' => queue, 'message' => RosettaQueue::Filters::process_receiving(message), 'headers' => headers}
end