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