This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new ef91c64c7c NIFI-14761 Replaced deprecated BasicThreadFactory.Builder
constructor with API suggestion (#10114)
ef91c64c7c is described below
commit ef91c64c7cb290f74bdf4215abbb7e9e601deb80
Author: dan-s1 <[email protected]>
AuthorDate: Mon Jul 21 17:20:28 2025 -0400
NIFI-14761 Replaced deprecated BasicThreadFactory.Builder constructor with
API suggestion (#10114)
Signed-off-by: David Handermann <[email protected]>
---
.../java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java | 2 +-
.../java/org/apache/nifi/processors/twitter/TweetStreamService.java | 2 +-
.../main/java/org/apache/nifi/ldap/tenants/LdapUserGroupProvider.java | 2 +-
.../controller/status/history/questdb/BufferedStatusHistoryStorage.java | 2 +-
.../java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java | 2 +-
.../org/apache/nifi/registry/provider/flow/git/GitFlowMetaData.java | 2 +-
6 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
index 8702cec125..9dd7b7876e 100644
---
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
+++
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
@@ -287,7 +287,7 @@ abstract class AbstractAMQPProcessor<T extends AMQPWorker>
extends AbstractProce
private AMQPResource<T> createResource(final ProcessContext context) {
Connection connection = null;
try {
- ExecutorService executor = Executors.newSingleThreadExecutor(new
BasicThreadFactory.Builder()
+ ExecutorService executor =
Executors.newSingleThreadExecutor(BasicThreadFactory.builder()
.namingPattern("AMQP Consumer: " + getIdentifier())
.build());
connection = createConnection(context, executor);
diff --git
a/nifi-extension-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
b/nifi-extension-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
index f9cd8f5f1a..4c01322368 100644
---
a/nifi-extension-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
+++
b/nifi-extension-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
@@ -108,7 +108,7 @@ public class TweetStreamService {
final String basePath =
context.getProperty(ConsumeTwitter.BASE_PATH).getValue();
api.getApiClient().setBasePath(basePath);
- threadFactory = new
BasicThreadFactory.Builder().namingPattern(ConsumeTwitter.class.getSimpleName()).build();
+ threadFactory =
BasicThreadFactory.builder().namingPattern(ConsumeTwitter.class.getSimpleName()).build();
}
public String getTransitUri(final String endpoint) {
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/src/main/java/org/apache/nifi/ldap/tenants/LdapUserGroupProvider.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/src/main/java/org/apache/nifi/ldap/tenants/LdapUserGroupProvider.java
index 3a812f9b0b..106e5a1782 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/src/main/java/org/apache/nifi/ldap/tenants/LdapUserGroupProvider.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/src/main/java/org/apache/nifi/ldap/tenants/LdapUserGroupProvider.java
@@ -146,7 +146,7 @@ public class LdapUserGroupProvider implements
UserGroupProvider {
@Override
public void initialize(final UserGroupProviderInitializationContext
initializationContext) throws AuthorizerCreationException {
final String namingPattern = String.format("%s (%s) - background sync
thread", getClass().getSimpleName(), initializationContext.getIdentifier());
- final ThreadFactory threadFactory = new BasicThreadFactory.Builder()
+ final ThreadFactory threadFactory = BasicThreadFactory.builder()
.daemon(true)
.namingPattern(namingPattern)
.build();
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb-status-history/src/main/java/org/apache/nifi/controller/status/history/questdb/BufferedStatusHistoryStorage.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb-status-history/src/main/java/org/apache/nifi/controller/status/history/questdb/BufferedStatusHistoryStorage.java
index 27f288823e..47fd6e4042 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb-status-history/src/main/java/org/apache/nifi/controller/status/history/questdb/BufferedStatusHistoryStorage.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb-status-history/src/main/java/org/apache/nifi/controller/status/history/questdb/BufferedStatusHistoryStorage.java
@@ -46,7 +46,7 @@ final class BufferedStatusHistoryStorage implements
StatusHistoryStorage {
private final String id = UUID.randomUUID().toString();
private final List<ScheduledFuture<?>> scheduledFutures = new
ArrayList<>();
private final ScheduledExecutorService scheduledExecutorService = Executors
- .newScheduledThreadPool(1, new
BasicThreadFactory.Builder().namingPattern("BufferedStatusHistoryStorage-" + id
+ "-%d").build());
+ .newScheduledThreadPool(1,
BasicThreadFactory.builder().namingPattern("BufferedStatusHistoryStorage-" + id
+ "-%d").build());
private final StatusHistoryStorage storage;
private final long persistFrequencyInMs;
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java
index 4b9bebd2ff..8ae89dc1d7 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java
@@ -58,7 +58,7 @@ final class EmbeddedDatabaseManager implements
DatabaseManager {
private final AtomicReference<CairoEngine> engine = new
AtomicReference<>();
private final List<ScheduledFuture<?>> scheduledFutures = new
ArrayList<>();
private final ScheduledExecutorService scheduledExecutorService = Executors
- .newScheduledThreadPool(2, new
BasicThreadFactory.Builder().namingPattern("EmbeddedQuestDbManagerWorker-" + id
+ "-%d").build());
+ .newScheduledThreadPool(2,
BasicThreadFactory.builder().namingPattern("EmbeddedQuestDbManagerWorker-" + id
+ "-%d").build());
EmbeddedDatabaseManager(final EmbeddedDatabaseManagerContext context) {
this.context = context;
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/provider/flow/git/GitFlowMetaData.java
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/provider/flow/git/GitFlowMetaData.java
index 1e3b86902b..8bf9abbd7e 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/provider/flow/git/GitFlowMetaData.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/provider/flow/git/GitFlowMetaData.java
@@ -273,7 +273,7 @@ class GitFlowMetaData {
return;
}
- final ThreadFactory threadFactory = new BasicThreadFactory.Builder()
+ final ThreadFactory threadFactory = BasicThreadFactory.builder()
.daemon(true).namingPattern(getClass().getSimpleName() + "
Push thread").build();
// Use scheduled fixed delay to control the minimum interval between
push activities.
