(nifi) branch main updated: NIFI-12834 Fixed ConsumeSlack NPE for latestReply field

[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 064e15b7be NIFI-12834 Fixed ConsumeSlack NPE for latestReply field
064e15b7be is described below

commit 064e15b7be0876a51f286b7a08c7023fc2d26cea
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Thu Feb 22 16:40:12 2024 -0500

    NIFI-12834 Fixed ConsumeSlack NPE for latestReply field
    
    This closes #8446
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../java/org/apache/nifi/processors/slack/consume/ConsumeChannel.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/ConsumeChannel.java
 
b/nifi-nar-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/ConsumeChannel.java
index 5dac540888..6533634fbb 100644
--- 
a/nifi-nar-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/ConsumeChannel.java
+++ 
b/nifi-nar-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/ConsumeChannel.java
@@ -634,7 +634,8 @@ public class ConsumeChannel {
 
         // If the message's latest reply is before our cutoff, don't bother 
polling for replies
         if (oldestTs != null) {
-            if (new SlackTimestamp(message.getLatestReply()).before(oldestTs)) 
{
+            final String latestReply = message.getLatestReply();
+            if (latestReply != null && new 
SlackTimestamp(latestReply).before(oldestTs)) {
                 return Collections.emptyList();
             }
         }