File tree 1 file changed +4
-2
lines changed
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -284,7 +284,8 @@ def synchronous_pull(project_id, subscription_name):
284
284
# Acknowledges the received messages so they will not be sent again.
285
285
subscriber .acknowledge (subscription_path , ack_ids )
286
286
287
- print ("Received and acknowledged {} messages. Done." .format (NUM_MESSAGES ))
287
+ print ('Received and acknowledged {} messages. Done.' .format (
288
+ len (response .received_messages )))
288
289
# [END pubsub_subscriber_sync_pull]
289
290
290
291
@@ -357,7 +358,8 @@ def worker(msg):
357
358
if processes :
358
359
time .sleep (SLEEP_TIME )
359
360
360
- print ("Received and acknowledged {} messages. Done." .format (NUM_MESSAGES ))
361
+ print ('Received and acknowledged {} messages. Done.' .format (
362
+ len (response .received_messages )))
361
363
# [END pubsub_subscriber_sync_pull_with_lease]
362
364
363
365
You can’t perform that action at this time.
0 commit comments