This is an automated email from the ASF dual-hosted git repository.

pvillard 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 ca4ee2407c NIFI-12515 Removed deprecated Client Auth property from 
AMQP processors
ca4ee2407c is described below

commit ca4ee2407cb01e23fba9ad5ae72151aa1fd8d10a
Author: Peter Turcsanyi <turcsa...@apache.org>
AuthorDate: Thu Dec 14 22:02:11 2023 +0100

    NIFI-12515 Removed deprecated Client Auth property from AMQP processors
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #8162.
---
 .../nifi/amqp/processors/AbstractAMQPProcessor.java      | 16 ++++++----------
 1 file changed, 6 insertions(+), 10 deletions(-)

diff --git 
a/nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
 
b/nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
index 1ef85a2b46..7e9dbc7008 100644
--- 
a/nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
+++ 
b/nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AbstractAMQPProcessor.java
@@ -38,12 +38,12 @@ import org.apache.nifi.components.PropertyDescriptor;
 import org.apache.nifi.components.ValidationContext;
 import org.apache.nifi.components.ValidationResult;
 import org.apache.nifi.expression.ExpressionLanguageScope;
+import org.apache.nifi.migration.PropertyConfiguration;
 import org.apache.nifi.processor.AbstractProcessor;
 import org.apache.nifi.processor.ProcessContext;
 import org.apache.nifi.processor.ProcessSession;
 import org.apache.nifi.processor.exception.ProcessException;
 import org.apache.nifi.processor.util.StandardValidators;
-import org.apache.nifi.security.util.ClientAuth;
 import org.apache.nifi.ssl.SSLContextService;
 
 
@@ -125,14 +125,6 @@ abstract class AbstractAMQPProcessor<T extends AMQPWorker> 
extends AbstractProce
             .allowableValues("true", "false")
             .addValidator(StandardValidators.BOOLEAN_VALIDATOR)
             .build();
-    public static final PropertyDescriptor CLIENT_AUTH = new 
PropertyDescriptor.Builder()
-            .name("ssl-client-auth")
-            .displayName("Client Auth")
-            .description("The property has no effect and therefore 
deprecated.")
-            .required(false)
-            .allowableValues(ClientAuth.values())
-            .defaultValue("NONE")
-            .build();
 
     private static final List<PropertyDescriptor> propertyDescriptors;
 
@@ -147,7 +139,6 @@ abstract class AbstractAMQPProcessor<T extends AMQPWorker> 
extends AbstractProce
         properties.add(AMQP_VERSION);
         properties.add(SSL_CONTEXT_SERVICE);
         properties.add(USE_CERT_AUTHENTICATION);
-        properties.add(CLIENT_AUTH);
         propertyDescriptors = Collections.unmodifiableList(properties);
     }
 
@@ -157,6 +148,11 @@ abstract class AbstractAMQPProcessor<T extends AMQPWorker> 
extends AbstractProce
 
     private BlockingQueue<AMQPResource<T>> resourceQueue;
 
+    @Override
+    public void migrateProperties(final PropertyConfiguration config) {
+        config.removeProperty("ssl-client-auth");
+    }
+
     @OnScheduled
     public void onScheduled(ProcessContext context) {
         resourceQueue = new 
LinkedBlockingQueue<>(context.getMaxConcurrentTasks());

Reply via email to