Skip to content

Commit cfbe3f5

Browse files
utkuaydinbshaffer
authored andcommitted
Acknowledge received Pub/Sub messages (GoogleCloudPlatform#382)
1 parent 9e61ffe commit cfbe3f5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pubsub/api/src/functions/pull_messages.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ function pull_messages($projectId, $subscriptionName)
4040
$subscription = $pubsub->subscription($subscriptionName);
4141
foreach ($subscription->pull() as $message) {
4242
printf('Message: %s' . PHP_EOL, $message->data());
43+
// Acknowledge the Pub/Sub message has been received, so it will not be pulled multiple times.
44+
$subscription->acknowledge($message);
4345
}
4446
}
4547
# [END pull_message]

0 commit comments

Comments
 (0)