177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
|
# File 'lib/fluent/plugin.rb', line 177
def configure(conf)
super
sysconf = if self.respond_to?(:owner) && owner.respond_to?(:system_config)
owner.system_config
elsif self.respond_to?(:system_config)
self.system_config
else
nil
end
if sysconf && sysconf.workers > 1 && !self.multi_workers_ready?
type = Fluent::Plugin.lookup_type_from_class(self.class)
raise Fluent::ConfigError, "Plugin '#{type}' does not support multi workers configuration (#{self.class})"
end
end
|