NIFI-12411: chore remove redundant variable assignment

Signed-off-by: Umar Hussain <umarhussain.work@gmail.com>
apache · Dec 15, 2023 · 8081da9 · 8081da9
1 parent 1dd6083
commit 8081da9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...undle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java b/...undle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java
@@ -335,9 +335,7 @@ private static String convertMapToJSONString(Map<String, Object> headers) throws
     @Override
     protected synchronized AMQPConsumer createAMQPWorker(final ProcessContext context, final Connection connection) {
         try {
-            final AMQPConsumer amqpConsumer = new AMQPConsumer(connection, queueName, autoAcknowledge,prefetchCount, getLogger());
-
-            return amqpConsumer;
+            return new AMQPConsumer(connection, queueName, autoAcknowledge, prefetchCount, getLogger());
         } catch (final IOException ioe) {
             throw new ProcessException("Failed to connect to AMQP Broker", ioe);
         }