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