(nifi) branch main updated: NIFI-15263 Fixed Missing migrateProperties in ListenUDP for Message Delimiter (#10564)

[exceptionfactory]

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 22358dc713 NIFI-15263 Fixed Missing migrateProperties in ListenUDP for 
Message Delimiter (#10564)
22358dc713 is described below

commit 22358dc7137c2af17b09c2e090ba0d3e7eaf5413
Author: Pierre Villard <pierre.villard...@gmail.com>
AuthorDate: Wed Nov 26 17:11:33 2025 +0100

    NIFI-15263 Fixed Missing migrateProperties in ListenUDP for Message 
Delimiter (#10564)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../util/listen/AbstractListenEventBatchingProcessor.java        | 6 ++++++
 .../java/org/apache/nifi/processors/standard/TestListenUDP.java  | 9 +++++++++
 2 files changed, 15 insertions(+)

diff --git 
a/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventBatchingProcessor.java
 
b/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventBatchingProcessor.java
index 10de0a4561..d9b8ce727b 100644
--- 
a/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventBatchingProcessor.java
+++ 
b/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventBatchingProcessor.java
@@ -19,6 +19,7 @@ package org.apache.nifi.processor.util.listen;
 import org.apache.nifi.annotation.lifecycle.OnScheduled;
 import org.apache.nifi.components.PropertyDescriptor;
 import org.apache.nifi.flowfile.FlowFile;
+import org.apache.nifi.migration.PropertyConfiguration;
 import org.apache.nifi.processor.ProcessContext;
 import org.apache.nifi.processor.ProcessSession;
 import org.apache.nifi.processor.ProcessorInitializationContext;
@@ -206,6 +207,11 @@ public abstract class 
AbstractListenEventBatchingProcessor<E extends Event> exte
         return batches;
     }
 
+    @Override
+    public void migrateProperties(final PropertyConfiguration config) {
+        
config.renameProperty(ListenerProperties.OLD_MESSAGE_DELIMITER_PROPERTY_NAME, 
ListenerProperties.MESSAGE_DELIMITER.getName());
+    }
+
     /**
      * @param event an event that was pulled off the queue
      *
diff --git 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java
 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java
index 8292556c15..0a04a7588e 100644
--- 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java
+++ 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java
@@ -23,6 +23,7 @@ import 
org.apache.nifi.processor.util.listen.ListenerProperties;
 import org.apache.nifi.processor.util.listen.dispatcher.ChannelDispatcher;
 import org.apache.nifi.processor.util.listen.event.StandardEvent;
 import org.apache.nifi.processor.util.listen.response.ChannelResponder;
+import org.apache.nifi.util.PropertyMigrationResult;
 import org.apache.nifi.provenance.ProvenanceEventRecord;
 import org.apache.nifi.provenance.ProvenanceEventType;
 import org.apache.nifi.util.MockFlowFile;
@@ -168,6 +169,14 @@ public class TestListenUDP {
         runner.assertAllFlowFilesTransferred(ListenUDP.REL_SUCCESS, 0);
     }
 
+    @Test
+    public void testMigrateProperties() {
+        final TestRunner migrationRunner = 
TestRunners.newTestRunner(ListenUDP.class);
+        final PropertyMigrationResult migrationResult = 
migrationRunner.migrateProperties();
+        assertEquals(ListenerProperties.MESSAGE_DELIMITER.getName(),
+                
migrationResult.getPropertiesRenamed().get(ListenerProperties.OLD_MESSAGE_DELIMITER_PROPERTY_NAME));
+    }
+
     @Test
     public void testWithSendingHostAndPortSameAsSender() throws IOException, 
InterruptedException {
         // bind to the same sending port that processor has for Sending Host 
Port