fix(fxgcppubsub): Fixed nack reactor

ankorstore · Jul 10, 2024 · b6ff89d · b6ff89d
1 parent 4d680e5
commit b6ff89d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fxgcppubsub/reactor/ack/reactor.go b/fxgcppubsub/reactor/ack/reactor.go
@@ -30,8 +30,8 @@ func (r *AckReactor) React(req any) (bool, any, error) {
 		r.supervisor.StopAckWaiter(ackReq.Subscription, ackReq.AckIds, nil)
 	}
 
-	if ackReq, ok := req.(*pubsubpb.ModifyAckDeadlineRequest); ok {
-		r.supervisor.StopNackWaiter(ackReq.Subscription, ackReq.AckIds, nil)
+	if modReq, ok := req.(*pubsubpb.ModifyAckDeadlineRequest); ok {
+		r.supervisor.StopNackWaiter(modReq.Subscription, modReq.AckIds, nil)
 	}
 
 	return false, nil, nil