Module: FastlyNsq::ListenerTesting

Included in:

Listener

Defined in:

lib/fastly_nsq/testing.rb

Defined Under Namespace

Modules: ClassMethods

Class Method Summary

• .prepended(klass) ⇒ Object

Instance Method Summary

• #connected? ⇒ Boolean
• #drain ⇒ Object
• #messages ⇒ Object
• #terminate ⇒ Object

Class Method Details

.prepended(klass) ⇒ Object

# File 'lib/fastly_nsq/testing.rb', line 219

def self.prepended(klass)
  klass.prepend(ClassMethods)
  super
end

Instance Method Details

#connected? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/fastly_nsq/testing.rb', line 230

def connected?
  return super unless FastlyNsq::Testing.enabled?
  @connected = true if @connected.nil?

  @connected
end

#drain ⇒ Object

Raises:

• (NoMethodError)

# File 'lib/fastly_nsq/testing.rb', line 237

def drain
  raise NoMethodError unless FastlyNsq::Testing.enabled?

  self.class.drain(topic)
end

#messages ⇒ Object

Raises:

• (NoMethodError)

# File 'lib/fastly_nsq/testing.rb', line 243

def messages
  raise NoMethodError unless FastlyNsq::Testing.enabled?

  self.class.messages(topic)
end

#terminate ⇒ Object

# File 'lib/fastly_nsq/testing.rb', line 224

def terminate
  return super unless FastlyNsq::Testing.enabled?

  @connected = false
end