Contents

module Toiler
  # Toiler's Worker behaviour
  module Worker
    def self.included(base)
      base.extend(ClassMethods)
      base.class_variable_set(:@@toiler_options, Toiler.default_options)
    end

    def log(level, message)
      Toiler.logger.log(level, message, self.class)
    end

    def error(msg)
      log Logger::Severity::ERROR, msg
    end

    def info(msg)
      log Logger::Severity::INFO, msg
    end

    def debug(msg)
      log Logger::Severity::DEBUG, msg
    end

    def warn(msg)
      log Logger::Severity::WARN, msg
    end

    def fatal(msg)
      log Logger::Severity::FATAL, msg
    end

    # Class methods for Workers
    module ClassMethods
      def toiler_options(options = {})
        return class_variable_get(:@@toiler_options) if options.empty?
        Toiler.register_worker(options[:queue], self) if options[:queue]
        class_variable_get(:@@toiler_options).merge! options
      end

      def batch?
        class_variable_get(:@@toiler_options)[:batch]
      end

      def concurrency
        class_variable_get(:@@toiler_options)[:concurrency]
      end

      def queue
        class_variable_get(:@@toiler_options)[:queue]
      end

      def auto_visibility_timeout?
        class_variable_get(:@@toiler_options)[:auto_visibility_timeout]
      end

      def auto_delete?
        class_variable_get(:@@toiler_options)[:auto_delete]
      end
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
toiler-0.6.1	lib/toiler/worker.rb
toiler-0.6.0	lib/toiler/worker.rb
toiler-0.6.0.pre1	lib/toiler/worker.rb
toiler-0.5.1	lib/toiler/worker.rb
toiler-0.5.1.pre9	lib/toiler/worker.rb
toiler-0.5.1.pre7	lib/toiler/worker.rb
toiler-0.5.1.pre6	lib/toiler/worker.rb
toiler-0.5.1.pre5	lib/toiler/worker.rb
toiler-0.5.1.pre4	lib/toiler/worker.rb
toiler-0.5.1.pre3	lib/toiler/worker.rb
toiler-0.5.1.pre2	lib/toiler/worker.rb
toiler-0.5.1.pre1	lib/toiler/worker.rb
toiler-0.5.0	lib/toiler/worker.rb
toiler-0.4.3	lib/toiler/worker.rb
toiler-0.4.2	lib/toiler/worker.rb