```ruby
module VMDB
  class Config
    class Activator
      include Vmdb::Logging

      def initialize(config)
        @config =
          if config.kind_of?(::Config::Options)
            config.to_hash
          elsif config.respond_to?(:config)
            config.config
          else
            config
          end
      end

      def activate
        raise "configuration invalid, see errors for details" unless Validator.new(@config).valid?

        @config.each_key do|k|
          if respond_to?(k.to_s, true)
            _log.debug("Activating #{k}")
            ost = OpenStruct.new(@config[k].stringify_keys)
            send(k.to_s, ost)
          end
        end
      end

      private

      def log(data)
        Vmdb::Loggers.apply_config(data)
      end

      def ntp(_data)
        MiqServer.my_server.ntp_reload_queue unless MiqServer.my_server.nil? rescue nil
      end

      def session(data)
        Session.timeout data.timeout
        Session.interval data.interval
      end

      def server(data)
        MiqServer.my_server.config_activated(data) unless MiqServer.my_server.nil? rescue nil
      end
    end
  end
end
```

Refresh the replication set when new worker config is saved
user
```ruby
module VMDB
  class Config
    class Activator
      include Vmdb::Logging

      def initialize(config)
        @config =
          if config.kind_of?(::Config::Options)
            config.to_hash
          elsif config.respond_to?(:config)
            config.config
          else
            config
          end
      end

      def activate
        raise "configuration invalid, see errors for details" unless Validator.new(@config).valid?

        @config.each_key do|k|
          if respond_to?(k.to_s, true)
            _log.debug("Activating #{k}")
            ost = OpenStruct.new(@config[k].stringify_keys)
            send(k.to_s, ost)
          end
        end
      end

      private

      def log(data)
        Vmdb::Loggers.apply_config(data)
      end

      def ntp(_data)
        MiqServer.my_server.ntp_reload_queue unless MiqServer.my_server.nil? rescue nil
      end

      def session(data)
        Session.timeout data.timeout
        Session.interval data.interval
      end

      def server(data)
        MiqServer.my_server.config_activated(data) unless MiqServer.my_server.nil? rescue nil
      end

      def workers(_data)
        pgl = MiqPglogical.new
        pgl.refresh_excludes if pgl.provider?
      end
    end
  end
end
```
assistant