Class: PulsarSdk::Consumer::Base::SeqGenerator

Inherits:
Object
  • Object
show all
Defined in:
lib/pulsar_sdk/consumer/base.rb

Overview

NOTE keep consumer_id and sequence_id static

Instance Method Summary collapse

Constructor Details

#initialize(seq_g) ⇒ SeqGenerator

Returns a new instance of SeqGenerator.



133
134
135
136
 
# File 'lib/pulsar_sdk/consumer/base.rb', line 133

def initialize(seq_g)
  @seq_g = seq_g
  @consumer_id = @seq_g.new_consumer_id
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method) ⇒ Object 



142
143
144
 
# File 'lib/pulsar_sdk/consumer/base.rb', line 142

def method_missing(method)
  @seq_g.public_send(method)
end

Instance Method Details

#new_consumer_id ⇒ Object 



138
139
140
 
# File 'lib/pulsar_sdk/consumer/base.rb', line 138

def new_consumer_id
  @consumer_id
end