class Discobolo::Config
Attributes
actor_concurrency[RW]
auth[RW]
client[RW]
fetch_options[RW]
queues[RW]
Public Class Methods
client=(nodes)
click to toggle source
# File lib/discobolo/config.rb, line 14 def self.client=(nodes) #client = Disque.new("127.0.0.1:7711", auth: "e727d1464a...") @client = Client.new(nodes) end
logger()
click to toggle source
# File lib/discobolo/config.rb, line 24 def self.logger @logger || Discobolo::Logger.new($stdout) end
logger=(arg=nil)
click to toggle source
# File lib/discobolo/config.rb, line 19 def self.logger=(arg=nil) l = arg.nil? ? arg : $stdout @logger = Discobolo::Logger.new(l) end
setup() { |self| ... }
click to toggle source
# File lib/discobolo/config.rb, line 10 def self.setup yield self end
Public Instance Methods
actor_concurrency()
click to toggle source
# File lib/discobolo/config.rb, line 28 def actor_concurrency @actor_concurrency || 5 end
fetch_options()
click to toggle source
# File lib/discobolo/config.rb, line 32 def fetch_options @fetch_options || {count: 10, timeout: 2000} end