Skip to content

Commit

Permalink
Fix NPE that occurs in PersistentStickyKeyDispatcherMultipleConsumers…
Browse files Browse the repository at this point in the history
… when debug log is enabled (apache#9587)
Masahiro Sakamoto authored Feb 16, 2021

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
1 parent 5763c0e commit c54a66f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
@@ -181,7 +181,7 @@ protected void sendMessagesToConsumers(ReadType readType, List<Entry> entries) {
maxMessagesForC, readType);
if (log.isDebugEnabled()) {
log.debug("[{}] select consumer {} with messages num {}, read type is {}",
name, consumer.consumerName(), messagesForC, readType);
name, consumer == null ? "null" : consumer.consumerName(), messagesForC, readType);
}

if (messagesForC < entriesWithSameKeyCount) {

0 comments on commit c54a66f

Please sign in to comment.