This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new c11c48f clean-up unnecessary public from interface (#3921)
c11c48f is described below
commit c11c48f9aa7075f1b1130a7249821587fef197b3
Author: Rajan Dhabalia <[email protected]>
AuthorDate: Thu Mar 28 15:50:46 2019 -0700
clean-up unnecessary public from interface (#3921)
---
.../src/main/java/org/apache/pulsar/client/admin/Namespaces.java | 8 ++++----
.../src/main/java/org/apache/pulsar/client/admin/Topics.java | 8 ++++----
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java
b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java
index db5a775..86da063 100644
---
a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java
+++
b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespaces.java
@@ -662,7 +662,7 @@ public interface Namespaces {
* @throws PulsarAdminException
* Unexpected error
*/
- public void setBacklogQuota(String namespace, BacklogQuota backlogQuota)
throws PulsarAdminException;
+ void setBacklogQuota(String namespace, BacklogQuota backlogQuota) throws
PulsarAdminException;
/**
* Remove a backlog quota policy from a namespace.
@@ -681,7 +681,7 @@ public interface Namespaces {
* @throws PulsarAdminException
* Unexpected error
*/
- public void removeBacklogQuota(String namespace) throws
PulsarAdminException;
+ void removeBacklogQuota(String namespace) throws PulsarAdminException;
/**
* Set the persistence configuration for all the topics on a namespace.
@@ -721,7 +721,7 @@ public interface Namespaces {
* @throws PulsarAdminException
* Unexpected error
*/
- public void setPersistence(String namespace, PersistencePolicies
persistence) throws PulsarAdminException;
+ void setPersistence(String namespace, PersistencePolicies persistence)
throws PulsarAdminException;
/**
* Get the persistence configuration for a namespace.
@@ -759,7 +759,7 @@ public interface Namespaces {
* @throws PulsarAdminException
* Unexpected error
*/
- public PersistencePolicies getPersistence(String namespace) throws
PulsarAdminException;
+ PersistencePolicies getPersistence(String namespace) throws
PulsarAdminException;
/**
* Set the retention configuration for all the topics on a namespace.
diff --git
a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java
b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java
index 691d0ab..bc705c7 100644
---
a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java
+++
b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java
@@ -829,7 +829,7 @@ public interface Topics {
* @throws PulsarAdminException
* Unexpected error
*/
- public void expireMessages(String topic, String subscriptionName, long
expireTimeInSeconds)
+ void expireMessages(String topic, String subscriptionName, long
expireTimeInSeconds)
throws PulsarAdminException;
/**
@@ -843,7 +843,7 @@ public interface Topics {
* Expire messages older than time in seconds
* @return
*/
- public CompletableFuture<Void> expireMessagesAsync(String topic, String
subscriptionName,
+ CompletableFuture<Void> expireMessagesAsync(String topic, String
subscriptionName,
long expireTimeInSeconds);
/**
@@ -857,7 +857,7 @@ public interface Topics {
* @throws PulsarAdminException
* Unexpected error
*/
- public void expireMessagesForAllSubscriptions(String topic, long
expireTimeInSeconds)
+ void expireMessagesForAllSubscriptions(String topic, long
expireTimeInSeconds)
throws PulsarAdminException;
/**
@@ -869,7 +869,7 @@ public interface Topics {
* @param expireTimeInSeconds
* Expire messages older than time in seconds
*/
- public CompletableFuture<Void>
expireMessagesForAllSubscriptionsAsync(String topic, long expireTimeInSeconds);
+ CompletableFuture<Void> expireMessagesForAllSubscriptionsAsync(String
topic, long expireTimeInSeconds);
/**
* Peek messages from a topic subscription