diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java index a6f6b30d1647..39941ae878fa 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java @@ -468,12 +468,6 @@ public boolean failOnFlowControlLimits() { return failOnFlowControlLimits; } - /** Retrieves a snapshot of the publisher current {@link PublisherStats statistics}. */ - public PublisherStats getStats() { - // TODO: Implement this. - throw new UnsupportedOperationException(); - } - /** * Schedules immediate publishing of any outstanding messages and waits until all are processed. * diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java index 915e914acb99..d15dcfed45a5 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java @@ -23,7 +23,7 @@ * Publisher}. */ @AutoValue -public abstract class PublisherStats { +abstract class PublisherStats { /** Number of successfully published messages. */ public abstract long getAckedMessages(); diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java index 2ee8b9194bf3..862e62d47ed9 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java @@ -365,11 +365,6 @@ public void run() { } } - public SubscriberStats getStats() { - // TODO: Implement me - return null; - } - /** Subscription which the subscriber is subscribed to. */ public String getSubscription() { return subscription; diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java index a96aff1d04b6..f0614f79a8f2 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java @@ -23,8 +23,8 @@ * Subscriber}. */ @AutoValue -public abstract class SubscriberStats { - +abstract class SubscriberStats { + @AutoValue //TODO: Finish implementation. public abstract static class Stats {}