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