Class: NATS::Subscription

Inherits:
Object
  • Object
show all
Includes:
MonitorMixin
Defined in:
lib/nats/io/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Subscription

Returns a new instance of Subscription.



1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
 
# File 'lib/nats/io/client.rb', line 1096

def initialize
  super # required to initialize monitor
  @subject  = ''
  @queue    = nil
  @future   = nil
  @callback = nil
  @response = nil
  @received = 0
  @max      = nil
end

Instance Attribute Details

#callback ⇒ Object

Returns the value of attribute callback.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def callback
  @callback
end

#future ⇒ Object

Returns the value of attribute future.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def future
  @future
end

#max ⇒ Object

Returns the value of attribute max.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def max
  @max
end

#queue ⇒ Object

Returns the value of attribute queue.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def queue
  @queue
end

#received ⇒ Object

Returns the value of attribute received.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def received
  @received
end

#response ⇒ Object

Returns the value of attribute response.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def response
  @response
end

#subject ⇒ Object

Returns the value of attribute subject.



1094
1095
1096
 
# File 'lib/nats/io/client.rb', line 1094

def subject
  @subject
end