From b6ff89df7eadd9885c0f3344bf6b01434c007a6c Mon Sep 17 00:00:00 2001 From: Jonathan Vuillemin Date: Wed, 10 Jul 2024 11:07:07 +0200 Subject: [PATCH] fix(fxgcppubsub): Fixed nack reactor --- fxgcppubsub/reactor/ack/reactor.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fxgcppubsub/reactor/ack/reactor.go b/fxgcppubsub/reactor/ack/reactor.go index 65f2702..5f8aab3 100644 --- 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