module FastlyNsq::ConsumerTesting
Public Class Methods
prepended(klass)
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 269 def self.prepended(klass) klass.prepend(ClassMethods) super end
Public Instance Methods
connect(*args)
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 285 def connect(*args) return super(*args) unless FastlyNsq::Testing.enabled? @connected = FakeConnection.new end
connected?()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 278 def connected? return super unless FastlyNsq::Testing.enabled? @connected = true if @connected.nil? @connected end
empty?()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 290 def empty? FastlyNsq::Testing.enabled? ? messages.empty? : super end
messages()
click to toggle source
# File lib/fastly_nsq/testing.rb, line 310 def messages raise NoMethodError unless FastlyNsq::Testing.enabled? FastlyNsq::Messages.messages[topic] end
pop()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 294 def pop FastlyNsq::Testing.enabled? ? messages(topic)&.pop : super end
pop_without_blocking()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 298 def pop_without_blocking FastlyNsq::Testing.enabled? ? messages(topic)&.pop : super end
size()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 302 def size FastlyNsq::Testing.enabled? ? messages.size : super end
terminate()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 274 def terminate FastlyNsq::Testing.enabled? || super end
terminated?()
click to toggle source
Calls superclass method
# File lib/fastly_nsq/testing.rb, line 306 def terminated? FastlyNsq::Testing.enabled? ? false : super end