class PulsarSdk::Options::Consumer

Attributes

listen_wait[RW]
name[RW]
prefetch[RW]
read_compacted[RW]
redelivery_delay[RW]
replicate_subscription_state[RW]
subscription_name[RW]
subscription_type[RW]
topic[RW]
topics[RW]
topics_pattern[RW]

Private Instance Methods

set_default() click to toggle source
# File lib/pulsar_sdk/options/consumer.rb, line 20
def set_default
  self.name = 'ruby-consumer.' + SecureRandom.urlsafe_base64(10)
  # 相同名字的subscription与订阅模式有关
  self.subscription_name = 'ruby-subscription'
  self.subscription_type = :Exclusive
  # 延迟消息重发,默认60秒
  self.redelivery_delay = 60
  # 记录预取数量
  self.prefetch = 1000
  self.replicate_subscription_state = true
  self.read_compacted = false
end