Class: Nsq::ClientBase

Inherits:

Object

• Object
• Nsq::ClientBase

Includes:

AttributeLogger

Defined in:

lib/nsq/client_base.rb

Direct Known Subclasses

Consumer, Producer

Constant Summary

@@log_attributes =

[:topic]

Instance Attribute Summary

• #connections ⇒ Object readonly

  Returns the value of attribute connections.

• #topic ⇒ Object readonly

  Returns the value of attribute topic.

Instance Method Summary

• #connected? ⇒ Boolean
• #terminate ⇒ Object

Methods included from AttributeLogger

included

Instance Attribute Details

#connections ⇒ Object (readonly)

Returns the value of attribute connections.

# File 'lib/nsq/client_base.rb', line 11

def connections
  @connections
end

#topic ⇒ Object (readonly)

Returns the value of attribute topic.

# File 'lib/nsq/client_base.rb', line 10

def topic
  @topic
end

Instance Method Details

#connected? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/nsq/client_base.rb', line 13

def connected?
  @connections.values.any?(&:connected?)
end

#terminate ⇒ Object

# File 'lib/nsq/client_base.rb', line 18

def terminate
  @discovery_thread.kill if @discovery_thread
  drop_all_connections
end