module Qyu
Constants
- SplitWorker
- SyncWorker
- VERSION
- Worker
Public Class Methods
config()
click to toggle source
# File lib/qyu.rb, line 27 def config fail 'Undefined configuration' unless defined?(@@__config) @@__config end
Also aliased as: configuration
configure(queue:, store:, logger: nil)
click to toggle source
# File lib/qyu.rb, line 18 def configure(queue:, store:, logger: nil) self.config = Qyu::Config.new( queue: queue, store: store ) self.logger = logger || default_logger unless defined?(@@__logger) self.test_connections end
configured?()
click to toggle source
# File lib/qyu.rb, line 34 def configured? defined?(@@__config) end
logger()
click to toggle source
# File lib/qyu.rb, line 42 def logger @@__logger ||= default_logger end
logger=(logger)
click to toggle source
# File lib/qyu.rb, line 38 def logger=(logger) @@__logger = logger end
queue()
click to toggle source
# File lib/qyu.rb, line 46 def queue @@__queue ||= Qyu::Factory::QueueFactory.get(config.queue) end
store()
click to toggle source
# File lib/qyu.rb, line 50 def store @@__store ||= Qyu::Factory::StoreFactory.get(config.store) end
test_connections()
click to toggle source
# File lib/qyu.rb, line 54 def test_connections queue store end
Private Class Methods
config=(config)
click to toggle source
# File lib/qyu.rb, line 61 def config=(config) fail 'Can not re-define configuration' if configured? fail 'Invalid configuration' unless config.is_a?(Qyu::Config) @@__config = config end
default_logger()
click to toggle source
# File lib/qyu.rb, line 68 def default_logger logger = Logger.new(STDOUT) logger.level = Logger::DEBUG logger end