NIFI-12834 Fixed ConsumeSlack NPE for latestReply field

This closes #8446

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Mark Payne 2024-02-22 16:40:12 -05:00 committed by exceptionfactory
parent e9b99ed04f
commit 064e15b7be
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
1 changed files with 2 additions and 1 deletions

View File

@ -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();
}
}