use existing context for gcp

2021-03-23 19:45:35 +00:00 · 2021-03-23 19:45:35 +00:00 · 2d0864d25c
parent 9fd461b255
commit 2d0864d25c
1 changed files with 1 additions and 1 deletions
--- a/pubsub/gcp/pubsub/pubsub.go
+++ b/pubsub/gcp/pubsub/pubsub.go
@ -233,7 +233,7 @@ func (g *GCPPubSub) handleSubscriptionMessages(topic *gcppubsub.Topic, sub *gcpp
 			Topic: topic.ID(),
 		}

-		err := handler(context.Background(), msg)
+		err := handler(ctx, msg)

 		if err == nil {
 			m.Ack()