class PulsarSdk::Consumer::Base::SeqGenerator

NOTE keep consumer_id and sequence_id static

Public Class Methods

new(seq_g) click to toggle source
# 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

Public Instance Methods

method_missing(method) click to toggle source
# File lib/pulsar_sdk/consumer/base.rb, line 142
def method_missing(method)
  @seq_g.public_send(method)
end
new_consumer_id() click to toggle source
# File lib/pulsar_sdk/consumer/base.rb, line 138
def new_consumer_id
  @consumer_id
end