Contents

# Handle Messaging and Queuing using JMS
module Qwirk
  module Adapter
    module Inline

      class WorkerConfig < Qwirk::Adapter::Base::WorkerConfig

        bean_attr_accessor :active, :boolean, 'Whether this worker is active or not', :config_item => true

        def self.default_marshal_sym
          :none
        end

        # Define the default config values for the attributes all workers will share.  These will be sent as options to the constructor
        def self.initial_default_config
          super.merge(:active => false)
        end

        def self.in_process?(config)
          true
        end

        # Hack - Steal attribute from expanding_worker_config so test config can share development config
        def min_count=(min_count)
          @active = (min_count > 0)
        end

        def create_worker
          Worker.new(self.name, self.marshaler)
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
qwirk-0.2.4	lib/qwirk/adapter/inline/worker_config.rb
qwirk-0.2.3	lib/qwirk/adapter/inline/worker_config.rb
qwirk-0.2.2	lib/qwirk/adapter/inline/worker_config.rb
qwirk-0.2.1	lib/qwirk/adapter/inline/worker_config.rb
qwirk-0.2.0	lib/qwirk/adapter/inline/worker_config.rb