remove subscribe timeout (#33)

osstotalsoft · Dec 22, 2021 · 3bd9ca2 · 3bd9ca2
1 parent 1e25ab1
commit 3bd9ca2
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/messaging/nats/nats.go b/pkg/messaging/nats/nats.go
@@ -241,9 +241,9 @@ func (n *natsStreamingPubSub) Subscribe(topic string, handler messaging.Handler,
 
 		//run handler concurrently
 		go func() {
-			newCtx, cancel := context.WithTimeout(n.ctx, parsedOptions.AckWait)
-			defer cancel()
-			err = handler(newCtx, &msg)
+			//newCtx, cancel := context.WithTimeout(n.ctx, parsedOptions.AckWait)
+			//defer cancel()
+			err = handler(n.ctx, &msg)
 			if err == nil {
 				// we only send a successful ACK if there is no error
 				natsMsg.Ack()