Skip to content

Commit 1f74c53

Browse files
committed
Logging: Drop remaining Settings log ctor (#34149)
Drops the last logging constructor that takes `Settings` because it is no longer needed. Watcher goes through a lot of effort to pass `Settings` to `Logger` constructors and dropping `Settings` from all of those calls allowed us to remove quite a bit of log-based ceremony from watcher.
1 parent eed50b4 commit 1f74c53

File tree

57 files changed

+162
-231
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

57 files changed

+162
-231
lines changed

plugins/discovery-file/src/main/java/org/elasticsearch/discovery/file/FileBasedDiscoveryPlugin.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.elasticsearch.common.logging.DeprecationLogger;
2323
import org.elasticsearch.common.logging.Loggers;
2424
import org.elasticsearch.common.network.NetworkService;
25-
import org.elasticsearch.common.settings.Settings;
2625
import org.elasticsearch.discovery.zen.UnicastHostsProvider;
2726
import org.elasticsearch.plugins.DiscoveryPlugin;
2827
import org.elasticsearch.plugins.Plugin;
@@ -38,8 +37,8 @@ public class FileBasedDiscoveryPlugin extends Plugin implements DiscoveryPlugin
3837
static final String DEPRECATION_MESSAGE
3938
= "File-based discovery is now built into Elasticsearch and does not require the discovery-file plugin";
4039

41-
public FileBasedDiscoveryPlugin(Settings settings) {
42-
deprecationLogger = new DeprecationLogger(Loggers.getLogger(this.getClass(), settings));
40+
public FileBasedDiscoveryPlugin() {
41+
deprecationLogger = new DeprecationLogger(Loggers.getLogger(this.getClass()));
4342
}
4443

4544
@Override

plugins/discovery-file/src/test/java/org/elasticsearch/discovery/file/FileBasedDiscoveryPluginDeprecationTests.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,13 @@
1919

2020
package org.elasticsearch.discovery.file;
2121

22-
import org.elasticsearch.common.settings.Settings;
2322
import org.elasticsearch.test.ESTestCase;
2423

2524
import static org.elasticsearch.discovery.file.FileBasedDiscoveryPlugin.DEPRECATION_MESSAGE;
2625

2726
public class FileBasedDiscoveryPluginDeprecationTests extends ESTestCase {
2827
public void testDeprecationWarning() {
29-
new FileBasedDiscoveryPlugin(Settings.EMPTY).getZenHostsProviders(null, null);
28+
new FileBasedDiscoveryPlugin().getZenHostsProviders(null, null);
3029
assertWarnings(DEPRECATION_MESSAGE);
3130
}
3231
}

server/src/main/java/org/elasticsearch/common/logging/Loggers.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import org.apache.logging.log4j.core.config.Configurator;
2929
import org.apache.logging.log4j.core.config.LoggerConfig;
3030
import org.elasticsearch.common.settings.Setting;
31-
import org.elasticsearch.common.settings.Settings;
3231
import org.elasticsearch.index.Index;
3332
import org.elasticsearch.index.shard.ShardId;
3433

@@ -65,16 +64,6 @@ public static Logger getLogger(Class<?> clazz, Index index, String... prefixes)
6564
return getLogger(clazz, asArrayList(Loggers.SPACE, index.getName(), prefixes).toArray(new String[0]));
6665
}
6766

68-
/**
69-
* Get a logger.
70-
* @deprecated prefer {@link #getLogger(Class, String...)} or {@link LogManager#getLogger}
71-
* as the Settings is no longer needed
72-
*/
73-
@Deprecated
74-
public static Logger getLogger(Class<?> clazz, Settings settings, String... prefixes) {
75-
return ESLoggerFactory.getLogger(formatPrefix(prefixes), clazz);
76-
}
77-
7867
public static Logger getLogger(Class<?> clazz, String... prefixes) {
7968
return ESLoggerFactory.getLogger(formatPrefix(prefixes), clazz);
8069
}

server/src/main/java/org/elasticsearch/index/analysis/AnalysisRegistry.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ public IndexAnalyzers build(IndexSettings indexSettings,
455455

456456
Index index = indexSettings.getIndex();
457457
analyzerProviders = new HashMap<>(analyzerProviders);
458-
Logger logger = Loggers.getLogger(getClass(), indexSettings.getSettings());
458+
Logger logger = Loggers.getLogger(getClass());
459459
DeprecationLogger deprecationLogger = new DeprecationLogger(logger);
460460
Map<String, NamedAnalyzer> analyzerAliases = new HashMap<>();
461461
Map<String, NamedAnalyzer> analyzers = new HashMap<>();

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/watcher/input/ExecutableInput.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
*/
66
package org.elasticsearch.xpack.core.watcher.input;
77

8-
import org.apache.logging.log4j.Logger;
98
import org.elasticsearch.common.Nullable;
109
import org.elasticsearch.common.xcontent.ToXContentObject;
1110
import org.elasticsearch.common.xcontent.XContentBuilder;
@@ -17,11 +16,9 @@
1716
public abstract class ExecutableInput<I extends Input, R extends Input.Result> implements ToXContentObject {
1817

1918
protected final I input;
20-
protected final Logger logger;
2119

22-
protected ExecutableInput(I input, Logger logger) {
20+
protected ExecutableInput(I input) {
2321
this.input = input;
24-
this.logger = logger;
2522
}
2623

2724
/**

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/Watcher.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -330,32 +330,32 @@ public Collection<Object> createComponents(Client client, ClusterService cluster
330330

331331
final ConditionRegistry conditionRegistry = new ConditionRegistry(Collections.unmodifiableMap(parsers), getClock());
332332
final Map<String, TransformFactory> transformFactories = new HashMap<>();
333-
transformFactories.put(ScriptTransform.TYPE, new ScriptTransformFactory(settings, scriptService));
333+
transformFactories.put(ScriptTransform.TYPE, new ScriptTransformFactory(scriptService));
334334
transformFactories.put(SearchTransform.TYPE, new SearchTransformFactory(settings, client, xContentRegistry, scriptService));
335335
final TransformRegistry transformRegistry = new TransformRegistry(Collections.unmodifiableMap(transformFactories));
336336

337337
// actions
338338
final Map<String, ActionFactory> actionFactoryMap = new HashMap<>();
339339
actionFactoryMap.put(EmailAction.TYPE, new EmailActionFactory(settings, emailService, templateEngine, emailAttachmentsParser));
340-
actionFactoryMap.put(WebhookAction.TYPE, new WebhookActionFactory(settings, httpClient, templateEngine));
340+
actionFactoryMap.put(WebhookAction.TYPE, new WebhookActionFactory(httpClient, templateEngine));
341341
actionFactoryMap.put(IndexAction.TYPE, new IndexActionFactory(settings, client));
342342
actionFactoryMap.put(LoggingAction.TYPE, new LoggingActionFactory(templateEngine));
343-
actionFactoryMap.put(HipChatAction.TYPE, new HipChatActionFactory(settings, templateEngine, hipChatService));
344-
actionFactoryMap.put(JiraAction.TYPE, new JiraActionFactory(settings, templateEngine, jiraService));
345-
actionFactoryMap.put(SlackAction.TYPE, new SlackActionFactory(settings, templateEngine, slackService));
346-
actionFactoryMap.put(PagerDutyAction.TYPE, new PagerDutyActionFactory(settings, templateEngine, pagerDutyService));
343+
actionFactoryMap.put(HipChatAction.TYPE, new HipChatActionFactory(templateEngine, hipChatService));
344+
actionFactoryMap.put(JiraAction.TYPE, new JiraActionFactory(templateEngine, jiraService));
345+
actionFactoryMap.put(SlackAction.TYPE, new SlackActionFactory(templateEngine, slackService));
346+
actionFactoryMap.put(PagerDutyAction.TYPE, new PagerDutyActionFactory(templateEngine, pagerDutyService));
347347
final ActionRegistry registry =
348348
new ActionRegistry(actionFactoryMap, conditionRegistry, transformRegistry, getClock(), getLicenseState());
349349

350350
// inputs
351351
final Map<String, InputFactory> inputFactories = new HashMap<>();
352352
inputFactories.put(SearchInput.TYPE, new SearchInputFactory(settings, client, xContentRegistry, scriptService));
353-
inputFactories.put(SimpleInput.TYPE, new SimpleInputFactory(settings));
353+
inputFactories.put(SimpleInput.TYPE, new SimpleInputFactory());
354354
inputFactories.put(HttpInput.TYPE, new HttpInputFactory(settings, httpClient, templateEngine));
355-
inputFactories.put(NoneInput.TYPE, new NoneInputFactory(settings));
356-
inputFactories.put(TransformInput.TYPE, new TransformInputFactory(settings, transformRegistry));
357-
final InputRegistry inputRegistry = new InputRegistry(settings, inputFactories);
358-
inputFactories.put(ChainInput.TYPE, new ChainInputFactory(settings, inputRegistry));
355+
inputFactories.put(NoneInput.TYPE, new NoneInputFactory());
356+
inputFactories.put(TransformInput.TYPE, new TransformInputFactory(transformRegistry));
357+
final InputRegistry inputRegistry = new InputRegistry(inputFactories);
358+
inputFactories.put(ChainInput.TYPE, new ChainInputFactory(inputRegistry));
359359

360360
bulkProcessor = BulkProcessor.builder(ClientHelper.clientWithOrigin(client, WATCHER_ORIGIN), new BulkProcessor.Listener() {
361361
@Override
@@ -457,7 +457,7 @@ protected WatchExecutor getWatchExecutor(ThreadPool threadPool) {
457457
}
458458

459459
protected Consumer<Iterable<TriggerEvent>> getTriggerEngineListener(ExecutionService executionService) {
460-
return new AsyncTriggerEventConsumer(settings, executionService);
460+
return new AsyncTriggerEventConsumer(executionService);
461461
}
462462

463463
@Override

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/actions/email/EmailActionFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
*/
66
package org.elasticsearch.xpack.watcher.actions.email;
77

8-
import org.elasticsearch.common.logging.Loggers;
8+
import org.apache.logging.log4j.LogManager;
99
import org.elasticsearch.common.settings.Settings;
1010
import org.elasticsearch.common.xcontent.XContentParser;
1111
import org.elasticsearch.xpack.core.watcher.actions.ActionFactory;
@@ -25,7 +25,7 @@ public class EmailActionFactory extends ActionFactory {
2525

2626
public EmailActionFactory(Settings settings, EmailService emailService, TextTemplateEngine templateEngine,
2727
EmailAttachmentsParser emailAttachmentsParser) {
28-
super(Loggers.getLogger(ExecutableEmailAction.class, settings));
28+
super(LogManager.getLogger(ExecutableEmailAction.class));
2929
this.emailService = emailService;
3030
this.templateEngine = templateEngine;
3131
this.htmlSanitizer = new HtmlSanitizer(settings);

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/actions/hipchat/HipChatActionFactory.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,7 @@
55
*/
66
package org.elasticsearch.xpack.watcher.actions.hipchat;
77

8-
import org.elasticsearch.common.logging.Loggers;
9-
import org.elasticsearch.common.settings.Settings;
8+
import org.apache.logging.log4j.LogManager;
109
import org.elasticsearch.common.xcontent.XContentParser;
1110
import org.elasticsearch.xpack.core.watcher.actions.ActionFactory;
1211
import org.elasticsearch.xpack.watcher.common.text.TextTemplateEngine;
@@ -20,8 +19,8 @@ public class HipChatActionFactory extends ActionFactory {
2019
private final TextTemplateEngine templateEngine;
2120
private final HipChatService hipchatService;
2221

23-
public HipChatActionFactory(Settings settings, TextTemplateEngine templateEngine, HipChatService hipchatService) {
24-
super(Loggers.getLogger(ExecutableHipChatAction.class, settings));
22+
public HipChatActionFactory(TextTemplateEngine templateEngine, HipChatService hipchatService) {
23+
super(LogManager.getLogger(ExecutableHipChatAction.class));
2524
this.templateEngine = templateEngine;
2625
this.hipchatService = hipchatService;
2726
}

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/actions/index/IndexActionFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
*/
66
package org.elasticsearch.xpack.watcher.actions.index;
77

8+
import org.apache.logging.log4j.LogManager;
89
import org.elasticsearch.client.Client;
9-
import org.elasticsearch.common.logging.Loggers;
1010
import org.elasticsearch.common.settings.Settings;
1111
import org.elasticsearch.common.unit.TimeValue;
1212
import org.elasticsearch.common.xcontent.XContentParser;
@@ -21,7 +21,7 @@ public class IndexActionFactory extends ActionFactory {
2121
private final TimeValue bulkDefaultTimeout;
2222

2323
public IndexActionFactory(Settings settings, Client client) {
24-
super(Loggers.getLogger(IndexActionFactory.class, settings));
24+
super(LogManager.getLogger(IndexActionFactory.class));
2525
this.client = client;
2626
this.indexDefaultTimeout = settings.getAsTime("xpack.watcher.actions.index.default_timeout", TimeValue.timeValueSeconds(30));
2727
this.bulkDefaultTimeout = settings.getAsTime("xpack.watcher.actions.bulk.default_timeout", TimeValue.timeValueMinutes(1));

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/actions/jira/JiraActionFactory.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,7 @@
55
*/
66
package org.elasticsearch.xpack.watcher.actions.jira;
77

8-
import org.elasticsearch.common.logging.Loggers;
9-
import org.elasticsearch.common.settings.Settings;
8+
import org.apache.logging.log4j.LogManager;
109
import org.elasticsearch.common.xcontent.XContentParser;
1110
import org.elasticsearch.xpack.core.watcher.actions.ActionFactory;
1211
import org.elasticsearch.xpack.watcher.common.text.TextTemplateEngine;
@@ -19,8 +18,8 @@ public class JiraActionFactory extends ActionFactory {
1918
private final TextTemplateEngine templateEngine;
2019
private final JiraService jiraService;
2120

22-
public JiraActionFactory(Settings settings, TextTemplateEngine templateEngine, JiraService jiraService) {
23-
super(Loggers.getLogger(ExecutableJiraAction.class, settings));
21+
public JiraActionFactory(TextTemplateEngine templateEngine, JiraService jiraService) {
22+
super(LogManager.getLogger(ExecutableJiraAction.class));
2423
this.templateEngine = templateEngine;
2524
this.jiraService = jiraService;
2625
}

0 commit comments

Comments
 (0)