class NATS::Subscription

Attributes

callback[RW]
future[RW]
is_slow_consumer[RW]
max[RW]
pending[RW]
pending_bytes_limit[RW]
pending_msgs_limit[RW]
pending_queue[RW]
pending_size[RW]
queue[RW]
received[RW]
response[RW]
subject[RW]
wait_for_msgs_t[RW]

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/nats/io/client.rb, line 1726
def initialize
  super # required to initialize monitor
  @subject  = ''
  @queue    = nil
  @future   = nil
  @callback = nil
  @response = nil
  @received = 0
  @max      = nil
  @pending  = nil

  # State from async subscriber messages delivery
  @pending_queue       = nil
  @pending_size        = 0
  @pending_msgs_limit  = nil
  @pending_bytes_limit = nil
  @wait_for_msgs_t     = nil
  @is_slow_consumer    = false
end