Fix some typos of the PersistentTopics
@@ -600,7 +600,6 @@ public class PersistentTopics extends PersistentTopicsBase {
@ApiParam(value = "Is authentication required to perform this operation")
@QueryParam("authoritative") @DefaultValue("false") boolean authoritative) {
validateTopicName(tenant, namespace, encodedTopic);
- validateTopicName(tenant, namespace, encodedTopic);
validateTopicPolicyOperation(topicName, PolicyName.MAX_UNACKED, PolicyOperation.WRITE);
preValidation(authoritative)
.thenCompose(__ -> internalSetMaxUnackedMessagesOnSubscription(null))
@@ -1767,7 +1766,7 @@ public class PersistentTopics extends PersistentTopicsBase {
.thenCompose(__ -> internalSetDeduplication(null))
.thenRun(() -> asyncResponse.resume(Response.noContent().build()))
.exceptionally(ex -> {
- handleTopicPolicyException("setDeduplication", ex, asyncResponse);
+ handleTopicPolicyException("removeDeduplication", ex, asyncResponse);
return null;
});
}
@@ -1858,7 +1857,7 @@ public class PersistentTopics extends PersistentTopicsBase {
asyncResponse.resume(Response.noContent().build());
})
.exceptionally(ex -> {
- handleTopicPolicyException("setRetention", ex, asyncResponse);
+ handleTopicPolicyException("removeRetention", ex, asyncResponse);
return null;
});
}
