File tree 1 file changed +3
-3
lines changed
google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -203,7 +203,7 @@ public ApiFuture<String> publish(PubsubMessage message) {
203
203
final OutstandingPublish outstandingPublish = new OutstandingPublish (publishResult , message );
204
204
messagesBatchLock .lock ();
205
205
try {
206
- // Check if the next message makes the batch exceed the current batch byte size.
206
+ // Check if the next message makes the current batch exceed the max batch byte size.
207
207
if (!messagesBatch .isEmpty ()
208
208
&& hasBatchingBytes ()
209
209
&& batchedBytes + messageSize >= getMaxBatchBytes ()) {
@@ -212,8 +212,8 @@ && hasBatchingBytes()
212
212
batchedBytes = 0 ;
213
213
}
214
214
215
- // Border case if the message to send is greater equals to the max batch size then can't be
216
- // included in the current batch and instead sent immediately.
215
+ // Border case if the message to send is greater or equals to the max batch size then can't
216
+ // be included in the current batch and instead sent immediately.
217
217
if (!hasBatchingBytes () || messageSize < getMaxBatchBytes ()) {
218
218
batchedBytes += messageSize ;
219
219
messagesBatch .add (outstandingPublish );
You can’t perform that action at this time.
0 commit comments