Skip to content

Commit 83eae0c

Browse files
authored
---
yaml --- r: 32019 b: refs/heads/autosynth-dialogflow c: d2f0bc6 h: refs/heads/master i: 32017: 725a3f8 32015: 1f188fc
1 parent 3ba527b commit 83eae0c

2 files changed

Lines changed: 16 additions & 8 deletions

File tree

  • branches/autosynth-dialogflow/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
@@ -128,7 +128,7 @@ refs/heads/autosynth-bigtable: 2a6af7e2959fd79c99b8ca5d773f29a6434b546d
128128
refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
129129
refs/heads/autosynth-containeranalysis: 18d210f81f17cf74864d0db2c29e834302f74f2a
130130
refs/heads/autosynth-datastore: f1efc3dc465174f41041acd56cf29badcec3e5bd
131-
refs/heads/autosynth-dialogflow: ff068a98c01b31c9cd416ff92e71c96ababcd204
131+
refs/heads/autosynth-dialogflow: d2f0bc64a53049040fe9c9d338b12fab3dd1ad6a
132132
refs/heads/autosynth-errorreporting: 3f176c20b55dfaaa8fc32f28d82b31784b93e636
133133
refs/heads/autosynth-firestore: 983c75e4fb1076502c8cac73ef0538bdb10884f3
134134
refs/heads/autosynth-iot: 4025d1804241e74d54950a324dc4f667aeaad4b3

branches/autosynth-dialogflow/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -272,13 +272,13 @@ public void publishAllOutstanding() {
272272
}
273273

274274
private ApiFuture<PublishResponse> publishCall(OutstandingBatch outstandingBatch) {
275-
PublishRequest.Builder publishRequest = PublishRequest.newBuilder();
276-
publishRequest.setTopic(topicName);
277-
for (OutstandingPublish outstandingPublish : outstandingBatch.outstandingPublishes) {
278-
publishRequest.addMessages(outstandingPublish.message);
279-
}
280-
281-
return publisherStub.publishCallable().futureCall(publishRequest.build());
275+
return publisherStub
276+
.publishCallable()
277+
.futureCall(
278+
PublishRequest.newBuilder()
279+
.setTopic(topicName)
280+
.addAllMessages(outstandingBatch.getMessages())
281+
.build());
282282
}
283283

284284
private void publishOutstandingBatch(final OutstandingBatch outstandingBatch) {
@@ -342,6 +342,14 @@ private static final class OutstandingBatch {
342342
int size() {
343343
return outstandingPublishes.size();
344344
}
345+
346+
private List<PubsubMessage> getMessages() {
347+
List<PubsubMessage> results = new ArrayList<>(outstandingPublishes.size());
348+
for (OutstandingPublish outstandingPublish : outstandingPublishes) {
349+
results.add(outstandingPublish.message);
350+
}
351+
return results;
352+
}
345353
}
346354

347355
private static final class OutstandingPublish {

0 commit comments

Comments
 (0)