Expose the publishAllOutstanding() method as public (#3093)

j256 · pongad · commit 1e79087946de · 2018-04-03T09:40:56.000-07:00
So that external systems that need to ensure that all messages have been
published can clear a batch.
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
@@ -290,7 +290,12 @@ public void run() {
     }
   }
 
-  private void publishAllOutstanding() {
+  /**
+   * Publish any outstanding batches if non-empty.   This method sends buffered messages, but does
+   * not wait for the send operations to complete.  To wait for messages to send, call {@code get}
+   * on the futures returned from {@code publish}.
+   */
+  public void publishAllOutstanding() {
     messagesBatchLock.lock();
     OutstandingBatch batchToSend;
     try {

Original file line number	Diff line number	Diff line change
`@@ -290,7 +290,12 @@ public void run() {`
`290`	`290`	`}`
`291`	`291`	`}`
`292`	`292`
`293`		`- private void publishAllOutstanding() {`
	`293`	`+ /**`
	`294`	`+ * Publish any outstanding batches if non-empty. This method sends buffered messages, but does`
	`295`	`+ * not wait for the send operations to complete. To wait for messages to send, call {@code get}`
	`296`	`+ * on the futures returned from {@code publish}.`
	`297`	`+ */`
	`298`	`+ public void publishAllOutstanding() {`
`294`	`299`	`messagesBatchLock.lock();`
`295`	`300`	`OutstandingBatch batchToSend;`
`296`	`301`	`try {`