class PulsarSdk::Producer::SeqGenerator
NOTE keep producer_id and sequence_id static
Public Class Methods
new(seq_g)
click to toggle source
# File lib/pulsar_sdk/producer/base.rb, line 134 def initialize(seq_g) @seq_g = seq_g @producer_id = @seq_g.new_producer_id @sequence_id = @seq_g.new_sequence_id end
Public Instance Methods
method_missing(method)
click to toggle source
# File lib/pulsar_sdk/producer/base.rb, line 149 def method_missing(method) @seq_g.public_send(method) end
new_producer_id()
click to toggle source
# File lib/pulsar_sdk/producer/base.rb, line 140 def new_producer_id @producer_id end
new_sequence_id(cache = true)
click to toggle source
# File lib/pulsar_sdk/producer/base.rb, line 144 def new_sequence_id(cache = true) return @sequence_id if cache @sequence_id = @seq_g.new_sequence_id end