Fixes handle exception when policy is updated.
@@ -1804,7 +1804,7 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
}
});
replicators.forEach((name, replicator) ->
- replicator.getRateLimiter().get().onPoliciesUpdate(data)
+ replicator.getRateLimiter().ifPresent(rateLimiter -> rateLimiter.onPoliciesUpdate(data))
);
checkMessageExpiry();
CompletableFuture<Void> replicationFuture = checkReplicationAndRetryOnFailure();
