commit 469077c09022917124ece518f6e5398421c972f0
author tmaret <tmaret@adobe.com> Sat May 11 16:11:32 2019 +0200
committer tmaret <tmaret@adobe.com> Sat May 11 16:11:32 2019 +0200
tree 3a0dd5626b6a35c84992d60a558be6399bbf8617
parent 2a6e6838b90927d789be05311f961b07ecd63e89

SLING-8415 - check for null subState

src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java

diff --git a/src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java b/src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java
index 91f0d71..f5ac277 100644
--- a/src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java
+++ b/src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java
@@ -209,9 +209,11 @@
         for (String subAgentId : view.getSubscribedAgentIds(pubAgentName)) {
             queueNames.add(subAgentId);
             State subState = view.getState(subAgentId, pubAgentName);
-            boolean errorQueueEnabled = (subState.getMaxRetries() >= 0);
-            if (errorQueueEnabled) {
-                queueNames.add(String.format("%s-error", subAgentId));
+            if (subState != null) {
+                boolean errorQueueEnabled = (subState.getMaxRetries() >= 0);
+                if (errorQueueEnabled) {
+                    queueNames.add(String.format("%s-error", subAgentId));
+                }
             }
         }
         return Collections.unmodifiableCollection(queueNames);