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