Skip to content

Commit

Permalink
Fix method comment for class Topics (apache#5106)
Browse files Browse the repository at this point in the history
  • Loading branch information
liketic authored and aahmed-se committed Sep 12, 2019
1 parent bd39e6c commit 9b375c2
Showing 1 changed file with 6 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -174,12 +174,9 @@ List<String> getListInBundle(String namespace, String bundleRange)
* Topic url
* @param role
* Client role to which remove permission
* @throws UniformInterfaceException
* if the operations was not successful
*
* @throws NotAuthorizedException
* Don't have admin permission
* @throws NotFound
* @throws NotFoundException
* Namespace does not exist
* @throws PreconditionFailedException
* Permissions are not set at the topic level
Expand Down Expand Up @@ -517,7 +514,7 @@ List<String> getListInBundle(String namespace, String bundleRange)
* "msgRateIn" : 100.0,
* "msgThroughputIn" : 10240.0,
* "msgRateOut" : 100.0,
* "msghroughputOut" : 10240.0,
* "msgThroughputOut" : 10240.0,
* "replicationBacklog" : 0,
* "connected" : true,
* }
Expand Down Expand Up @@ -698,7 +695,7 @@ List<String> getListInBundle(String namespace, String bundleRange)
* Get the stats for the partitioned topic
*
* @param topic
* @param perPartition
* topic name
* @return
* @throws PulsarAdminException
*/
Expand Down Expand Up @@ -822,7 +819,7 @@ PartitionedTopicInternalStats getPartitionedInternalStats(String topic)
*
* @param topic
* topic name
* @param subName
* @param subscriptionName
* Subscription name
* @param expireTimeInSeconds
* Expire messages older than time in seconds
Expand All @@ -837,7 +834,7 @@ void expireMessages(String topic, String subscriptionName, long expireTimeInSeco
*
* @param topic
* topic name
* @param subName
* @param subscriptionName
* Subscription name
* @param expireTimeInSeconds
* Expire messages older than time in seconds
Expand Down Expand Up @@ -1000,7 +997,7 @@ void createSubscription(String topic, String subscriptionName, MessageId message
* topic name
* @param subName
* Subscription name
* @param MessageId
* @param messageId
* reset subscription to messageId (or previous nearest messageId if given messageId is not valid)
*/
CompletableFuture<Void> resetCursorAsync(String topic, String subName, MessageId messageId);
Expand Down

0 comments on commit 9b375c2

Please sign in to comment.