---

pongad · web-flow · commit 0212f4f13da9 · 2017-01-24T12:02:34.000+11:00
yaml --- r: 5347 b: refs/heads/master c: 302a937 h: refs/heads/master i: 5345: c265f48 5343: 21c167f
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 51a9a804df74a1bb8e85c2b2e5f8571ef783ba30
+refs/heads/master: 302a937773699d3348db0d17ea6a78ebeccbbc52
 refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
 refs/heads/gh-pages: 229631582f8957646f81e92ae5a326504f48ee5b
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java b/trunk/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/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java b/trunk/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/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java b/trunk/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/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java b/trunk/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 {}

Original file line number	Diff line number	Diff line change
`@@ -468,12 +468,6 @@ public boolean failOnFlowControlLimits() {`
`468`	`468`	`return failOnFlowControlLimits;`
`469`	`469`	`}`
`470`	`470`
`471`		`- /** Retrieves a snapshot of the publisher current {@link PublisherStats statistics}. */`
`472`		`- public PublisherStats getStats() {`
`473`		`- // TODO: Implement this.`
`474`		`- throw new UnsupportedOperationException();`
`475`		`- }`
`476`		`-`
`477`	`471`	`/**`
`478`	`472`	`* Schedules immediate publishing of any outstanding messages and waits until all are processed.`
`479`	`473`	`*`
Original file line number	Diff line number	Diff line change
`@@ -365,11 +365,6 @@ public void run() {`
`365`	`365`	`}`
`366`	`366`	`}`
`367`	`367`
`368`		`- public SubscriberStats getStats() {`
`369`		`- // TODO: Implement me`
`370`		`- return null;`
`371`		`- }`
`372`		`-`
`373`	`368`	`/** Subscription which the subscriber is subscribed to. */`
`374`	`369`	`public String getSubscription() {`
`375`	`370`	`return subscription;`