def main_process(&block)
Process.setproctitle("worker:#{@process_name}") if @process_name
begin
block.call
rescue Fluent::ConfigError
$log.error "config error", file: @config_path, error: $!.to_s
$log.debug_backtrace
unless @log.stdout?
console = Fluent::Log.new(STDOUT, @log_level).enable_debug
console.error "config error", file: @config_path, error: $!.to_s
console.debug_backtrace
end
rescue
$log.error "unexpected error", error: $!.to_s
$log.error_backtrace
unless @log.stdout?
console = Fluent::Log.new(STDOUT, @log_level).enable_debug
console.error "unexpected error", error: $!.to_s
console.error_backtrace
end
end
exit! 1
end