module Plugin

Public Instance Methods

client(c, plugin: nil) click to toggle source
# File lib/plugin.rb, line 6
def client(c, plugin: nil)
  plugin = init_plugin(plugin)
  c ||= Mqjob.default_client

  Plugin.const_get(plugin).new(c)
end

Private Instance Methods

init_plugin(name) click to toggle source
# File lib/plugin.rb, line 13
def init_plugin(name)
  name ||= Mqjob.config.plugin

  Mqjob.logger.debug("#{self.name}::#{__method__}"){"select plugin: #{name}"}

  require "plugin/#{name}"

  name.to_s.capitalize
end