Skip to content

Commit ff6eac3

Browse files
authored
---
yaml --- r: 26239 b: refs/heads/pubsub-ordering-keys c: e492b04 h: refs/heads/master i: 26237: 1d632a1 26235: a75735c 26231: 0e6895c 26223: 05293c3 26207: 6fa229d 26175: 2dadc63 26111: 98470d7
1 parent f33d08b commit ff6eac3

2 files changed

Lines changed: 4 additions & 5 deletions

File tree

  • branches/pubsub-ordering-keys/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ refs/tags/v0.72.0: a7703f2593ba312c0b2dde6fdfd4f5c764bb55ac
155155
refs/tags/v0.73.0: 21241ea8be9439cc5764c4944cdce21d34ce4f9e
156156
refs/tags/v0.74.0: 9d1f733dbbf790de7b494418523b69c4a9a57638
157157
refs/heads/ignoretest: 23c412ae07af3d0ab1caa2d44d5bc5c0ccb8b31d
158-
refs/heads/pubsub-ordering-keys: 3f9a663ac6aa026f8344500cac8bdddede78f09f
158+
refs/heads/pubsub-ordering-keys: e492b044bb05efc54b5ad1a9fd4aefc021e8ff84
159159
"refs/heads/update_mvn_badge": ae2d773814db0f71197ccf5a8612ee1d8056f8de
160160
refs/tags/v0.75.0: c3673089ae09a897c1b4cf7dfe167fe4f8ab32fb
161161
refs/tags/v0.76.0: 395b016826d3ddf9cb8b34919636df15a4dbd032

branches/pubsub-ordering-keys/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -391,8 +391,7 @@ public void onFailure(Throwable t) {
391391
Runnable task =
392392
new Runnable() {
393393
public void run() {
394-
ApiFutures.addCallback(
395-
publishCall(outstandingBatch), futureCallback, directExecutor());
394+
ApiFutures.addCallback(publishCall(outstandingBatch), futureCallback, directExecutor());
396395
}
397396
};
398397
executor.execute(task);
@@ -703,11 +702,11 @@ private static class MessagesBatch {
703702
private int batchedBytes;
704703
private String orderingKey;
705704

706-
public MessagesBatch(String orderingKey) {
705+
private MessagesBatch(String orderingKey) {
707706
this.orderingKey = orderingKey;
708707
}
709708

710-
public OutstandingBatch popOutstandingBatch() {
709+
private OutstandingBatch popOutstandingBatch() {
711710
OutstandingBatch batch = new OutstandingBatch(messages, batchedBytes, orderingKey);
712711
reset();
713712
return batch;

0 commit comments

Comments
 (0)