Module: FastlyNsq::ListenerTesting::ClassMethods

Defined in:
lib/fastly_nsq/testing.rb

Instance Method Summary collapse

Instance Method Details

#clear ⇒ Object 



214
215
216
 
# File 'lib/fastly_nsq/testing.rb', line 214

def clear
  FastlyNsq::Messages.messages.clear
end

#drain(topic = nil) ⇒ Object 



202
203
204
205
206
207
208
209
210
211
212
 
# File 'lib/fastly_nsq/testing.rb', line 202

def drain(topic = nil)
  topics = topic ? [topic] : FastlyNsq::Messages.messages.keys
  topics.each do |t|
    messages = FastlyNsq::Messages.messages[t]
    next unless messages.any?
    listener = FastlyNsq.manager.topic_listeners[t]
    next unless listener

    messages.dup.each { |message| listener.call(message) }
  end
end

#messages(topic = nil) ⇒ Object 



196
197
198
199
200
 
# File 'lib/fastly_nsq/testing.rb', line 196

def messages(topic = nil)
  return FastlyNsq::Messages.messages.values.flatten unless topic

  FastlyNsq::Messages.messages[topic]
end