revert: to ack without results

PrimaKu · Aug 12, 2024 · 5457347 · 5457347
1 parent 78c9c69
commit 5457347
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/client.go b/client.go
@@ -185,12 +185,8 @@ func (c *Client) Subscribe(ctx context.Context, subscriptionId string, conf Subs
 			return
 		}
 
-		result, err := msg.AckWithResult().Get(ctx)
-		if err != nil {
-			fmt.Printf("[pubsub][onMessageAckErr] err: %v", err)
-			return
-		}
-		fmt.Printf("[pubsub][onMessageAcked] status: %d, messageId: %s", result, message.Id)
+		msg.Ack()
+		fmt.Printf("[pubsub][onMessageAcked] id: %s", message.Id)
 	})
 }